<\/span><\/h2>\nAnother way to test the connection to a Kafka broker is by using a programming language client, such as Java, Python, or Node.js. Below is a code snippet demonstrating how to test the connection using the KafkaProducer and KafkaConsumer in Java:<\/p>\n
“`java
\nimport org.apache.kafka.clients.producer.KafkaProducer;
\nimport org.apache.kafka.clients.producer.ProducerRecord;
\nimport org.apache.kafka.clients.consumer.KafkaConsumer;
\nimport org.apache.kafka.clients.consumer.ConsumerRecords;
\nimport org.apache.kafka.clients.consumer.ConsumerRecord;
\nimport java.util.Properties;<\/p>\n
public class KafkaConnectionTest {
\n public static void main(String[] args) {
\n Properties props = new Properties();
\n props.put(“bootstrap.servers”, “localhost:9092”);
\n props.put(“key.serializer”, “org.apache.kafka.common.serialization.StringSerializer”);
\n props.put(“value.serializer”, “org.apache.kafka.common.serialization.StringSerializer”);<\/p>\n
KafkaProducer producer = new KafkaProducer<>(props);
\n producer.send(new ProducerRecord<>(“test”, “Testing Kafka connection”));<\/p>\n KafkaConsumer consumer = new KafkaConsumer<>(props);
\n consumer.subscribe(Collections.singletonList(“test”));
\n ConsumerRecords records = consumer.poll(1000);<\/p>\n for (ConsumerRecord record : records) {
\n System.out.println(record.value());
\n }<\/p>\n consumer.close();
\n producer.close();
\n }
\n}
\n“`<\/p>\n
If the code runs without any errors and you can see the “Testing Kafka connection” message printed to the console, it means that the connection to the Kafka broker is functional.<\/p>\n