共有1个答案
正如在注释中已经提到的，您需要使用SDK从客户机动态创建订阅，并在客户机脱机后删除订阅。
不要认为有任何其他比这更好的方法，因为客户的数量可能会上升或下降。
-
有人能帮我弄清楚这件事吗。 谢了！
-
< li >我在Kubernetes集群中部署并运行了Kafka。我使用的图片来自docker hub-https://hub . docker . com/r/cloudtrackinc/kubernetes-Kafka/ < li >我的kubernetes群集中有3个kube节点。我有3个Kafka和3个zookeeper应用程序在运行，我有服务zoo1、zoo2、zoo3和kafka-1、
-
我正在使用Apache Camel的AMQP组件来收听来自ActiveMQ Artemis主题的消息。 此应用程序在Kubernetes上运行，有两个副本。 我已经配置了一个持久订阅，每个pod有一个唯一的clientId和一个通用订阅名称： 问题是两个pod都接收消息，而只有一个应该接收。我正在尝试实现类似于Kafka的消费者组的东西，其中只有一个组成员接收每条消息。
-
我想知道对于quartz是否有一个简单的解决方案/hack来触发一个在集群中的每个节点上都被删除的作业。 我的情况：我的应用程序正在缓存一些东西，并且运行在一个没有分布式缓存的集群中。现在，我需要刷新作业触发的所有节点上的缓存。
-
我正在开发一个使用的软件。我有一个用户订阅了多个主题，我想知道是否有一个订单接收来自这些主题的消息。我在我的电脑上尝试了一些组合，但我需要确定这一点。例 null [编辑]我想指定这两个主题各有一个分区，并且只有一个生产者和一个消费者。我需要首先阅读来自第一个主题的所有消息，然后阅读来自另一个主题的消息
-
我有一个场景，我已经在不同的节点上部署了4个Kafka消费者实例。我的主题有4个分区。现在，我想配置消费者，使他们都从主题的不同分区获取。 我知道一个事实，如果消费者来自同一个消费者组，他们会确保分区被平分。但在我的情况下，他们不在同一组。