小编Ano*_*ous的帖子

我创建了一个示例应用程序来检查我的生产者的代码。当我在没有分区键的情况下发送数据时，我的应用程序运行良好。但是，在指定数据分区的键时，我收到错误：

[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error while fetching metadata with correlation id 37 : {myTest=UNKNOWN_TOPIC_OR_PARTITION}
[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error while fetching metadata with correlation id 38 : {myTest=UNKNOWN_TOPIC_OR_PARTITION}
[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error while fetching metadata with correlation id 39 : {myTest=UNKNOWN_TOPIC_OR_PARTITION}

对于消费者和生产者来说。我在互联网上搜索了很多，他们建议验证 kafka.acl 设置。我在 HDInsight 上使用 kafka，但我不知道如何验证它并解决此问题。

我的集群有以下配置：

1. 头节点：2
2. 工作节点：4
3. 动物园管理员：3

我的生产者代码：

public static void produce(String brokers, String topicName) throws IOException{

    // Set properties …

我正在开发一个应用程序，我需要在 Hdinsight 和事件中心之间进行选择。我在互联网上进行了全面搜索，但找不到它们之间的任何具体比较。我想从一些有经验的 azure 用户那里了解这一点。

PS这不是一个基于意见的问题。