小编moh*_*itg的帖子

我是Kafka的新手并运行了一个简单的kafka消费者/制作人示例,如KafkaConsumer和KafkaProducer所示.当我从终端运行消费者时,消费者正在接收消息,但我无法使用Java代码进行监听.我也在StackoverFlow上搜索了类似的问题(链接:Link1,Link2)并尝试了解决方案,但似乎没有什么对我有用.Kafka版本:kafka_2.10-0.10.2.1和相应的maven依赖在pom中使用.

生产者和消费者的Java代码:

public class SimpleProducer {
public static void main(String[] args) throws InterruptedException {
    Properties props = new Properties();
    props.put("bootstrap.servers", "localhost:9094");
    props.put("acks", "all");
    props.put("retries", 0);
    props.put("batch.size", 16384);
    props.put("linger.ms", 1);
    props.put("buffer.memory", 33554432);
    props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
    props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

    Producer<String, String> producer = new KafkaProducer<>(props);
    for(int i = 0; i < 10; i++)
        producer.send(new ProducerRecord<String, String>("topic3", Integer.toString(i), Integer.toString(i)));

    producer.close();

}}

public class SimpleConsumer {

public static void main(String[] args) {
    Properties props = new …