英文:
Kafka Consumer doesn't always receive messages
问题
以下是您提供的内容的中文翻译：
所以我有一个 Kafka 消费者，但它并不总是从我的生产者接收消息，我不确定是否与 Zookeeper/Kafka 服务器随机死机或代码有关。
想知道这是否是一个常见问题？
生产者：
public SentenceProducer() {
Properties properties = new Properties();
properties.put("bootstrap.servers", "localhost:9092");
properties.put("client.id", SentenceProducer.class.getName());
producer = new KafkaProducer(properties, new StringSerializer(), new StringSerializer());
}
消费者：
public SentenceConsumer() {
Properties properties = new Properties();
properties.put("bootstrap.servers", "localhost:9092");
properties.put("client.id", SentenceConsumer.class.getName());
properties.put("group.id", "test");
consumer = new KafkaConsumer(properties, new StringDeserializer(), new StringDeserializer());
consumer.subscribe(Collections.singletonList("sentence"));
detector = new LanguageDetector();
}
英文:
So I have this Kafka Consumer but it isn't always receiving messages from my producer and I'm not sure if it has to do with the Zookeeper/Kafka servers dying randomly or something to do with the code.
Was wondering if this is a common issue?
Producer:
public SentenceProducer() {
Properties properties = new Properties();
properties.put("bootstrap.servers", "localhost:9092");
properties.put("client.id", SentenceProducer.class.getName());
producer = new KafkaProducer(properties, new StringSerializer(), new StringSerializer());
}
Consumer:
public SentenceConsumer() {
Properties properties = new Properties();
properties.put("bootstrap.servers", "localhost:9092");
properties.put("client.id", SentenceConsumer.class.getName());
properties.put("group.id", "test");
consumer = new KafkaConsumer(properties, new StringDeserializer(), new StringDeserializer());
consumer.subscribe(Collections.singletonList("sentence"));
detector = new LanguageDetector();
}
专注分享java语言的经验与见解，让所有开发者获益！
评论