Не могу подключиться к брокеру Kafka с помощью Java SDK ⇐ JAVA

[Anonymous]

Я создал тему Kafka с одним разделом и без репликации на моем локальном хосте, протестировал передачу сообщений через потребителя консоли Kafka и производителя консоли, и все работало нормально, но при попытке отправить сообщение через клиент Java sdk, используя следующий код. Сообщение тайм-аут истекает, и я не вижу этого на консольном потребителе, который использует ту же тему. Требуются ли какие-либо изменения в свойствах?
Properties properties =new Properties();
properties.setProperty("bootstrap.servers", "127.0.0.1:9092");
properties.setProperty("key.serializer", StringSerializer.class.getName());
properties.setProperty("value.serializer", StringSerializer.class.getName());
properties.setProperty("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
properties.setProperty("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
KafkaProducer producer =new KafkaProducer(properties);
ProducerRecord producerRecord = new ProducerRecord("one","hello abhishek");
producer.send(producerRecord);


Подробнее здесь: https://stackoverflow.com/questions/790 ... g-java-sdk