Spring Kafka-在运行时订阅新主题
问候
共有1个答案
不能在运行时动态添加主题；您必须停止/启动容器才能开始收听新主题。
您可以@autowireKafkalistenerEndpointRegistry和通过ID停止/启动监听器。
您还可以通过调用注册表本身的stop()/start()来停止/启动所有侦听器。
-
https://github.com/azure/azure-service-bus/tree/master/samples/dotnet/gettingstart/microsoft.azure.servicebus/topicsubscriptionwithruleoperationssample 现在我想添加一个筛选器/规则，这样只有通过筛选器中定义的特定条件的消息才应该给订阅。 例如,下面
-
我正在配置一个Apache Artemis消息代理。代理将接受大文件，下游消费者访问该主题以处理最新文件。现在我想知道如何使最新文件可用于开发运行。因为消息一天只到达几次，所以测试运行需要访问最近发送的几条消息，不能等待下一条。 对于生产和登台系统，我发现持久订阅工作良好。我已经改编了ApacheCamel配置作为示例。以下是两个接收消息的消费者，每个消费者都使用持久订阅： 这很好。如果一个消费者
-
我正在试验消息驱动Beans，以便从外部ActiveMQ实例接收主题订阅消息。 我的测试首先从队列订阅开始，它工作得很好。 然后我想尝试主题订阅，但我无法让它工作。 这就是我所拥有的： 会议记录。xml 这是MDB： 我不知道为什么，但从日志中我可以看到，TomEE创建了一个队列，而不是一个主题： 另一个证明是，当我添加持续时间配置时，服务器不会启动： 然后服务器抱怨这不适合配置类型javax.j
-
在什么情况下Spring webflow会进行订阅？我在任何地方都读到必须有订阅，否则不会发生任何更改。在我使用Spring Webflow的短暂时间里，我从未在控制器或服务中见过。 我的疑问还在于，在使用flatMap时，。。。等订阅在什么时候进行？ 我所读的并不能真正解决我的疑虑。 我知道这是一个异步问题，但每个flatMap都同时运行？。。。所以有时候我注意到一些数据是空的。
-
我想在一个主题上放一个BrokeredMessage。有些订阅者必须立即处理。一个或多个订阅服务器必须在第二天才开始处理。 我曾经研究过使用BrokeredMessage.ScheduleDenQueueTimeUTC属性来延迟队列和主题上的消息处理，但这意味着所有订阅者都将延迟它们的处理。 我的想法是，我应该在不延迟入队时间的情况下将BrokeredMessage添加到主题中，并在一个订阅服务器
-
目前，我已经开始使用ActiveMQ处理JMS主题。我已经通过JAVA代码（如下所述）创建了发布者和持久订阅者，并且在订阅者端也收到了消息。 Publisher.Java 订阅者.java 我对以下主题有一些疑问， 如何检查有多少订阅者使用 Java JMS 在主题中主动查找消息？ 如何从主题中获取活动和持久订阅者列表？ 我们是否可以删除主题中发布的消息？ 在这些情况下帮助我。 提前致谢。
-
我想使用PublishSubject创建一个广播系统，一个后台任务将轮询一些endpoint，并定期使用该主题广播结果。我希望在第一个订阅者订阅主题时开始轮询，并在没有更多订阅者时停止轮询。如果有新订阅者订阅，则应继续轮询。
-
我试图利用固有的WSO2ESB主题发布到jms队列。我已经创建了主题，并提供了一个订阅者URL：jms：/topictest？transport.jms.destinationtype=queue。然而，当我将消息发布到主题时，它不能被传递到队列。日志生成以下内容 “系统无法从jms：/queue？destination=topictest URL推断传输信息。” 另外，我似乎不知道如何发布到WS