强制Kafka客户端停止读取主题中的消息
我有以下情况：我使用Kafka模板，以便与Kafka交互，但我希望能够以编程方式防止Kafka客户端从某个主题读取消息，但仍然能够产生到其他主题。有没有办法实现这一点？
共有1个答案
您可以在需要时启动和停止监听器-请参阅此答案。
您可以设置ACL来保护主题，如果这就是您所说的“阻止”的意思的话。
https://kafka.apache.org/documentation/#security_authz
-
我的应用程序使用来自RabbitMQ的一些消息并对其进行处理。我有大约10个队列，每个队列最多有10个消费者（线程）。我有5次预回迁。我正在Heroku中使用CloudAMQP插件（RabbitMQ作为服务）运行安装程序。 我使用默认心跳和连接超时设置（60秒）运行。 我的java应用程序是一个使用sping-Rabbit库的Spring Boot应用程序。 版本： 问题是对于一个特定队列的消费者
-
我们最近对我们的Kafka集群进行了Kerbertic化，我们开始在阅读来自代理上的主题的消息时遇到问题。 我们使用的是spring kafka 1.1.2版本和kafka client 0.10.0.1。 在研究了Apache Kafka文档中的建议之后，我在项目中做了以下更改。 在使用者属性中添加了security.protocol SASL_PLAINTEXT。 添加了适当的JAAS文件，并
-
2016-07-05 03:59:25.042 O.A.S.D.Executor[INFO]正在处理-2元组的接收消息:源：__System:-1，流：__Tick，ID:{}，[30] 2016-07-05 03:59:25.946 O.A.S.D.Executor[INFO]正在处理-2元组的接收消息:源：__System:-1，流：__Metrics_Tick，ID:{}，[60] 我的测试
-
我有一个Kafka集群（版本：0.10.1.0），有9个代理和10个分区。 我尝试使用camel kafka从java应用程序中获取消息。这是我的pom。xml 这只是我使用的与骆驼Kafka相关的依赖项。下面是骆驼Kafka消费者代码。 我正在使用文档中指定的KafkaURIhttps://camel.apache.org/components/latest/kafka-component.ht
-
我是Apache Kafka的一个新用户，我还在了解它的内部结构。 在我的用例中，我需要从Kafka Producer客户端动态增加一个主题的分区数量。 我发现了关于增加分区大小的其他类似问题，但它们使用了zookeeper配置。但是我的kafkaProducer只有Kafka broker配置，而没有zookeeper配置。 有没有什么方法我可以增加一个主题的分区数量从生产者端？我运行的是Kaf
-
我们使用Akka流Kafka来生成和消费消息和Strimzi Kafka集群。以下是相关版本： 重构消息发出后，消费者停止工作。我们在主题中确实有一些信息，但消费者只是在无休止地等待。 以下是日志片段： 还有一些要点： 架构注册表配置正确且良好（否则生产者将无法工作）。 主题（和组协调器）很好，我可以通过这样的普通消费者消费消息： 这就是代码卡住的地方——我使用阻塞调用获取2条消息（甚至无法获取1