aIbrahiim commented on issue #30513: URL: https://github.com/apache/beam/issues/30513#issuecomment-5045504666
hey, yeah i think #39284 is related. after that PR bumped kafka to 3.9.2 and swapped `KafkaServerStartable` -> `KafkaServer`, the local test broker in `LocalKafka` still uses the old `port` / `log.dir` settings. those don't 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`), but that's just the follow-on — the real issue is the broker isn't reachable. so not a missing topic / test flake in the usual sense. looks like leftover config from the kafka 3.9 upgrade. -- 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]
