我有一个多节点Kafka集群，我能够成功地创建主题，这在zookeeper日志中是清楚的。但是我不能发送/接收来自某些主题的消息，即使它们是创建的。
另外，我没有看到为3个节点的kafka代理的/tmp/kafka logs目录中的一些主题创建的日志。
例如：如果我创建了topic1…topic5。我可以收发主题3，主题4的信息。我有我的生产者和消费者在node1运行。知道我做错什么了吗？
制片人方面：

private Properties producerConfig() {
  Properties props = new Properties();
  props.put("bootstrap.servers", "host1:9092,host2:9092,host3:9092");
  props.put("acks", "all");
  props.put("retries", 0);
  props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
  props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

return props;
}

消费者方面：

private Properties createConsumerConfig(String zookeeper, String groupId) {
        Properties props = new Properties();
        props.put("zookeeper.connect", "host1:2181,host2:2181,host3:2181");
        props.put("group.id", groupId);
        props.put("auto.commit.enable", "false");
        props.put("auto.offset.reset", "smallest");

        return props;
      }

多节点群集设置：
我使用了以下说明来设置多节点集群。

Host1 :: zk1,kafkabroker1
Host2 :: zk2,kafkabroker2
Host3 :: zk3,kafkabroker3

https://itblog.adrian.citu.name/2014/01/30/how-to-set-an-apache-kafka-multi-node-multi-broker-cluster/