仅当某些条件为真时才使用来自Kafka的消息
-
null
当应用程序正在消费消息时，但随后consumeEnabled变成false的情况就没有必要考虑了。
请定义用Spring Kafka和\或Kafka Java客户机实现决策的最佳方式
共有1个答案
如果您使用的是@kafkalistener，那么
@KafkaListener(id = "foo", ... , autoStartup="${consume.enabled}")
其中consume.enabled是一个属性。
要在运行时启动/停止容器，请使用KafkalistenerEndpointRegistrybean。
registry.getListenerContainer("foo").start();
-
问题内容： 我正在使用以下查询： 但是，我也想将其作为条件，因此它将执行以下操作： 如果 不到20分钟前（）。 正确： 更新，添加一个，然后更新。 False： 所有字段均应保持相同。 我不太确定该怎么做，但是环顾四周之后，我尝试在零件中使用“声明” 。 但是我收到以下错误： 问题答案： 您使用的IF语句不正确 因此，IF检查条件并返回作为其参数提供的两个值之一。参见MySQL的流控制运算符。
-
问题内容： 如果我在if块内创建变量，则以后将无法使用它。如果我在if块之前创建一个变量，而if块的计算结果为false，则会出现“变量已创建且未使用”的错误。 我敢肯定，这是设计使然，我正在尝试做我不应该做的事情，但是我想做的事情背后的逻辑对我来说很有意义。如果url中有页面信息，我以后想在sql语句中使用它，但是如果url中没有页面信息，则不需要这些变量。 http://pastebin.co
-
下面是网页的HTML代码。 而且 我正在执行一个基于这样一个条件的程序：如果某个文本被显示，那么我必须点击动态按钮。如果下列条件为真 driver.findElements（by.xpath（“//div[starts-with(@id,'qwer')]//a[contains(text(),'holiday')]”）； 然后我会点击页面上的所有按钮 下面是这方面的程序。运行此程序后，它将执行el
-
我使用amqp.node库集成Rabbitmq到我的系统。 但是在消费者中，我想一次只处理一条消息，然后确认消息，然后从队列中消费下一条消息。 目前的代码是： ch.consume将一次处理通道中的所有消息，模块的功能在这里调用，其他模块不会在同一时间线执行。 我想等待othermodule函数完成，然后再使用队列中的下一条消息。
-
我使用elasticsearch 0.90.2和elasticsearch river mongodb 1.7.0从mongodb的oplog中检索数据。在我试图索引的集合中，我有数千条结构化记录，让我们把它们命名为“field1”、“field2”、“field3”字段10' 有没有办法只索引“field1”和“field2”？这些是字符串还是日期对象有关系吗？ 谢啦
-
我有一个spring boot应用程序与单个Kafka消费者从一些主题获取消息。但有时在处理消息时会出现错误。 我理解我需要禁用自动提交并手动提交成功的消息，但是，在这种情况下，如果我没有为这个异常情况抛出任何异常，并手动提交每个下一个成功的消息，那么我将丢失前一个不成功的消息，对吗？