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

【问题标题】：Kafka Consumer API not subscribing using Java clientKafka Consumer API 未使用 Java 客户端订阅
【发布时间】：2017-10-10 13:55:45
【问题描述】：

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

设置：生产者发布消息。使用./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9093 --topic TEST.TOPIC --time -1计数的主题发送消息

问题订阅时轮询消费者不起作用，但如果您手动分配（） - 它可以工作。在同一个问题上有一个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");

【问题讨论】：

你使用的是命令行消费者吗？你能分享一下消费者的配置吗？
已更新。我正在使用 Java 客户端（KafkaConsumer）。当我使用 subscribe(topics) - 不起作用。分配（主题分区） - 作品。
你在kafka属性中设置了以下属性吗？ etc/kafka/server.properties usually. listeners=PLAINTEXT://<ip>:<port> 这告诉 kafka 以纯文本（vs ssl）在这里收听消费者。
是的。 listeners=PLAINTEXT://:9093
客户端和服务器版本相同？