chia7712 commented on PR #19964: URL: https://github.com/apache/kafka/pull/19964#issuecomment-3029093279
> Not sure why the cluster keeps reformatting. However, the default [delivery.timeout.ms](https://kafka.apache.org/documentation/#producerconfigs_delivery.timeout.ms) is 120 secs, which is too long for the test. In our case, it's ok for a producer.send() to fail. We just want to make sure that every callback is called. So, we could at least reduce [delivery.timeout.ms](https://kafka.apache.org/documentation/#producerconfigs_delivery.timeout.ms). The root cause is that the default partition count is '2', while the re-created partition count is '1'. Hence, the produce request sent to topic-1, which the topic is auto-created, can never be completed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org