Error in Flink process Kafka topic:java.net.ConnectException: Connection refused (Connection refused)
I have a Flink program which must be connected to Kafka topic as a consumer and process it.
I already set Kafka server.properties:
Apache Flink Kafka source properties.group.id to Kafka consumer group
I created a Flink table with Kafaka source like the following:
Flink Job design – working with hybrid Kafka topic
I have a kafka topic that contains few events types.(This is given)
The events are JSON documents.