共有1个答案
一个简短的回答--当前版本的Kafka不支持这种开箱即用的功能。由于Kafka生产者被设计为在单个会话期间与多个代理进行通信，因此没有简单的方法来实现这种特殊过滤。仍然存在两个合理的选择：
- 使用两个主题：一个“公共”主题向所有人开放，允许所有消息；另一个非公共“过滤”主题，在应用过滤规则后，您自己的应用程序将使用来自“公共”的数据填充该主题。
- 如果您绝对需要在写下传入消息之前验证它们，那么您可以将实际的Kafka代理隐藏在某种形式的代理应用程序后面，该代理应用程序将在将消息写入Kafka之前进行验证
-
我有一个问题与产生的消息Kafka的主题。 我使用来自外部供应商的Kafka管理服务，所以我问他经纪人的状况，他说一切都好。顺便说一句，它发生在三个不同的Kafka实例上。Kafka客户端版本也无关紧要-0.11.0.0和2.0.1都有。
-
我是Kafka的新手，正在开发一个原型，将专有的流媒体服务连接到Kafka中。 我希望得到一个主题上发送的最后一条消息的密钥，因为我们的内部流消费者需要用连接时收到的最后一条消息的ID登录。 我尝试使用使用者执行以下操作，但当同时运行控制台使用者时，我看到消息被重播。 这是意料之中的行为还是我走错了路？
-
我是Kafka的新手，当我试图发送信息到我得到的主题下面的错误。有人能帮我一下吗？ [2018-09-23 13:37:56,613]警告[Producer Clientid=Console-Producer]无法建立到节点-1的连接。代理可能不可用。（org.apache.kafka.clients.NetworkClient）
-
我正在使用kafka java客户端和kafka服务器。 我的代码： Kafka马纳格 当我的循环长度如果在1000左右（在类)时，我就能成功地向Kafka主题发送数据。 但当我的循环长度为1或小于10时，我无法向Kafka主题发送数据。注意我没有得到任何错误。 根据我的发现，如果我想发送一个单一的消息到Kafka主题，根据这个程序我得到了成功的消息，但从来没有得到一个关于我的主题的消息。 但是如
-
我无法将KafkaProducer使用java从Windows（主机操作系统）上的eclipse发送到运行在Hortonworks沙箱上的kafka主题。我的java代码如下所示 当我运行这个java代码时没有错误，它只是打印消息的索引，在本例中只有0，然后终止，我无法在hortonworks沙箱的cmd接口上的console-consumer中看到0。 这是pom.xml依赖项 我可以从制片人那
-
我在向我的Kafka主题发送序列化XML时遇到问题。每当我运行我的代码时，我都不会收到任何异常或错误消息，但我仍然无法在Kafka主题中看到我的任何消息。 我的Kafka制作人设置如下： 当我运行代码时，我得到： 知道怎么做吗？提前谢谢！