aIbrahiim commented on issue #30513: URL: https://github.com/apache/beam/issues/30513#issuecomment-5045550204
> I'm curious if not related - [#39284](https://github.com/apache/beam/pull/39284) @stankiewicz yeah i think #39284 is related. after that PR bumped kafka to 3.9.2 and swapped KafkaServerStartable to KafkaServer the local test broker in LocalKafka still uses the old port / log.dir settings and those dont actually bind a listener on kafka 3.x anymore so the broker never comes up in the postcommit logs you see stuff like: Connection to node -1 (localhost/127.0.0.1:...) could not be established. Node may not be available and then it surfaces as the topic metadata timeout (Topic ... not present in metadata after 60000 ms), so i think the real issue is the broker isn't reachable but the new upgrade broke theKafka test harness -- 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]
