Kafka client is not concurrency safe. Its the responsibility of callee to manage the concurrency.
| 58 | // Kafka client is not concurrency safe. |
| 59 | // Its the responsibility of callee to manage the concurrency. |
| 60 | type kafkaSinkClient struct { |
| 61 | client sarama.Client |
| 62 | producer sarama.SyncProducer |
| 63 | } |
| 64 | |
| 65 | func newKafkaSink(config *z.SuperFlag) (Sink, error) { |
| 66 | if config.GetString("kafka") == "" { |
nothing calls this directly
no outgoing calls
no test coverage detected