Node.js program that publish and subscribe to messages using Apache Kafka

 

This program creates a Kafka producer and a Kafka consumer and subscribes the consumer to a topic. The producer then publishes a message on the topic, and the consumer receives and prints the message. The program also handles disconnections and reconnections to Kafka.