dajudge/kafkaproxy

Connection Problem with Kafka 3 and Java Client

x29a opened this issue · 0 comments

x29a commented

Hi,

when trying to connect to a Kafka 3 broker via the kafkaproxy with the Java Kafka Library in version greater than 2.8.1, consume does not work because it seems that the kafkaproxy is announcing the real brokers hostname (kafka1) instead of itself (e.g. localhost).

I wrote a MRE in this branch which updates the brokers and then uses the Java Kafka Library to produce 10 messages to a topic and then tries to consume them.

Producing works, when consuming one can see with DEBUG loglevel: java.net.UnknownHostException: kafka1 instead of the expected localhost.

Thanks for the great product!