首页 文章

Kafka Consumer API未使用Java客户端订阅

提问于
浏览 次
0

Kafka：0.10.1.0（客户端和服务器）Java客户端 . 动物园管理员：3.4.6

Setup ： 生产环境 者发布消息 . 使用 ./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9093 --topic TEST.TOPIC --time -1 发送有关主题的消息

Issue 订阅时轮询的消费者不起作用，但如果您手动分配（） - 它可以工作 . 在同一个问题上有一个separate thread但没有回答 . 它可能是UUID问题但需要更多细节，因为我们正在评估阶段，细节会有所帮助 .

消费者设置：props.put（“bootstrap.servers”，服务器）; props.put（“enable.auto.commit”，ENABLE_AUTO_COMMIT）;

props.put("auto.commit.interval.ms", AUTO_COMMIT_INTERVAL_MS);
    props.put("session.timeout.ms", SESSION_TIMEOUT_MS);
    props.put("group.id", CONSUMER_GROUP_ID);
    props.put("key.deserializer", STRING_DESRIALIZER);
    props.put("value.deserializer", STRING_DESRIALIZER);
    props.put("auto.offset.reset", "earliest");
apache-kafka kafka-consumer-api

1 回答

  • 0

    问题出在Kafka版本上 .

    切换到0.10.2.1（服务器和客户端）和subscribe（）完美地工作 .

    回复于

相关问题