Connection to node 432 (localhost/127.0.0.1:9094) could not be established. Broker may not be available

Hi! Could you please advise why I can't run Kafka broker with different port number ? It's working fine with default port 9092, but when I change it to 9093 or 9094 for instance, I get the following errors: [2022-05-30 13:16:28,456] DEBUG [BrokerToControllerChannelManager broker=432 name=forwa

Connection to node 432 (localhost/127.0.0.1:9094) could not be established. Broker may not be available

Hi! Could you please advise why I can't run Kafka broker with different port number ? It's working fine with default port 9092, but when I change it to 9093 or 9094 for instance, I get the following errors: [2022-05-30 13:16:28,456] DEBUG [BrokerToControllerChannelManager broker=432 name=forwa

Newbie how to get key/value pojo out of a stream?

All the Kstream examples I have found demonstrate how to use map, filter, and join on streams. The last step they typically user to() to publish/produce the results to a new stream How can I get the data out of the stream? For example I need to send the data to a legacy data that can not use kafka

Re: Newbie how to get key/value pojo out of a stream?

Hi Andy, If I understand your problem correctly, you want a "foreach" terminal operation. You can check out the API here: https://kafka.apache.org/32/documentation/streams/developer-guide/dsl-api.html Luca On Tue, May 31, 2022, at 6:37 AM, Andy wrote: > All the Kstream examples I have found de