Ling Jin

> So depending on how the AsyncProducer is configured and the type of network error, it might look the producer is stuck but it is actually mostly idle because of...

Consider the following scenario: For a totally new Kafka cluster, there do not exist any topics yet, user tries to fetch metadata, then creates the topic by calling `admin.CreateTopic` method....

Any update to the issue ? Our service use sarama to implement the producer originally, and it suffers from several problems inside the library so that we decide try this...

Any update on this? Sarama version v1.36.0 Go version 1.19 Kafka 3.x

How about set the `BatchSize` to 1, this should skip the batch.

/retest

/test cdc-integration-kafka-test

/retest

/test cdc-integration-kafka-test

/retest