无法使用java sdk连接到kafka代理

Question

我创建了一个只有一个分区且在本地主机上没有复制的 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<String,String> producer =new KafkaProducer<String, String>(properties);
ProducerRecord <String,String> producerRecord = new ProducerRecord<>("one","hello abhishek");
producer.send(producerRecord);

Answer 1

消息超时

Kafka 在刷新间隔后或发送

batch.size

数量的字节时批量发送数据

如果发少了一定要打电话

producer.flush()