You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
the kafka component is overwriting a global sarama client variable, the data race produces when one component is running and using the sarama log and concurrently another kafka component is initializing.
Steps to Reproduce the Problem
Release Note
RELEASE NOTE:
The text was updated successfully, but these errors were encountered:
Expected Behavior
Kafka component supports to run and initialize multiple instances concurrently
Actual Behavior
I was writing some tests using the kafka component and I'm having a data race when running tests in parallel.
The data race is due to this https://github.com/dapr/components-contrib/blob/main/common/component/kafka/kafka.go#L190
the kafka component is overwriting a global sarama client variable, the data race produces when one component is running and using the sarama log and concurrently another kafka component is initializing.
Steps to Reproduce the Problem
Release Note
RELEASE NOTE:
The text was updated successfully, but these errors were encountered: