nileshkumar3 opened a new pull request, #22325: URL: https://github.com/apache/kafka/pull/22325
## Summary `KafkaStreamsTelemetryIntegrationTest.shouldPushGlobalThreadMetricsToBroker` is flaky because `EmbeddedKafkaCluster.createTopic` only waits until the topic name appears in `listTopics()`, not until partition metadata has fully propagated. The `GlobalStreamThread` then calls `partitionsFor()` during initialization and fails fast when the broker returns an empty partition list: wait in @BeforeEach until describeTopics reports the expected partition count for the global store source topic before starting Kafka Streams. Reviewers : @muralibasani @mjsax -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
