《消息》专题

Flink kafka消费者有两种类型的消费者，例如： 这两个消费者层次结构扩展了相同的类。我想知道维护编号类背后的设计决策是什么？我们什么时候应该使用其中一种？ 我注意到带有数字后缀的类有更多的特性（例如ratelimiting）。 https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka

我将Apache Camel与Oracle高级队列和JMS结合使用时遇到了问题。 它是关于一个分发消息的应用程序。消息在Camel的帮助下被接收并在Oracle高级队列中排队。然后它们被Camel使用并转发到目标系统。对于消息传递失败的情况，在高级队列中定义了重试计数，以便重复消息传递。 如果Camel现在将消息退出队列并将其发送到不可用的目标系统，则会引发HttpOperationFailedE

我正在编写一个简单的discord bot，我想让它在加入服务器时发送一条问候消息 但是，此代码只发送一般消息，如果一般通道未命名为“general”，则不会发送。现在我希望它在系统消息通道中发送消息。我该怎么做？

我试图提出一个设计，使用Kafka为多个处理代理并行处理来自Kafka主题的消息。 null 或者还有什么我遗漏的地方可能有助于我对这一点的理解？

假设我对同一个消息键有不同的值。 例如： 在上述情况下，我只需要用户更新的最新值，即“user789@xyz.com”。 我的kafka流应该只给我第三个值，而不是前两个值。

访问者订阅，我检索FCM令牌。 我使用POST将此消息推送到https://fcm.googleapis.com/fcm/send 它总是说成功=1， 但事实上，只有当网站关闭时，信息才会被传递！ 当我关闭选项卡并再次推送消息时，消息被传递。 此外，如果我打开网站或我去该领域的任何地方，如http://example.org/whatever/，但仍返回“success=1”。 测试了Chrome

我正在尝试使用Firebase云消息传递（FCM）在一个适用于网络和移动的多平台应用程序中实现一个消息传递子系统。FCM允许您以两种格式发送消息：通知和数据。 通知由平台显示，例如，在web平台上的一个小弹出窗口中，或添加到移动电话上的通知列表中。 数据消息由应用程序处理。 在应用程序可以接收消息之前，您必须向用户请求发送/接收通知的权限。 现在，当用户阻止通知时，数据消息似乎也被阻止了。是我漏了

假设kafka消息生产者向一个主题发送一条事件消息。然后一个消费者处理这个事件消息。但是，这个消费者进程因为业务错误而抛出异常，所以他想让消息生产者知道它并再次怨恨。 有什么解决办法吗？

我需要从两个队列加载消息，并且我使用ActiveMQ，我必须实现重试机制，以防出现任何错误或网络或应用程序服务器故障并加载回同一个队列。此外，我想将任何有害消息加载到DLQ。 请让我知道我是否可以通过Spring JMS实现这些。此外，请提供一些很好的例子来完成这项任务。我检查了Spring JMS留档，没有太多细节。

我正在看华为推送套件在Android系统中是如何工作的。为此，我使用邮递员发送通知，我发送通知消息和数据消息。在通知区域中可以看到通知消息，但我无法获得我在数据消息中发送的数据。我想知道如何得到他们都当应用程序在前台和后台。

我有一个SOAP Web服务，它发送一个kafka请求消息，并等待一个kafka响应消息（例如，consumer.poll(10000))。 每次调用web服务时，它都会创建一个新的Kafka生产者和一个新的Kafka消费者。 每次调用web服务时，使用者都会收到相同的消息（例如，具有相同偏移量的消息）。 我使用的是Kafka0.9，启用了自动提交，并且自动提交频率为100毫秒。 更新0001

我正在使用@StreamListener（Spring-Cloud-Stream）来使用来自主题（输入通道）的消息，进行一些处理并保存到一些缓存或数据库中。 我的要求是，如果DB在处理消费的消息时停止，我想暂停主消费者(输入通道)，并从另一个主题(输入56通道)开始消费，一旦它消费了来自输入56通道的所有消息(没有很多)，我想再次恢复主消费者(输入通道)。 这能做到吗？？

我正在尝试配置一个rsyslog服务器来接收来自docker容器的日志。我目前正在使用以下突击队来运行docker容器： 我使用rfc5424，因为从docker到rsyslog的标准日志格式在冒号字符处中断消息，拆分标记remote：shouldshow并将shouldshow添加到消息中。有关此情况的更多信息，请参见：https://github.com/docker/docker/issue

Kafka consumer有一个配置< code>max.poll.records,它控制对poll()的单次调用中返回的最大记录数，其默认值为500。我将它设置为一个很高的数字，这样我就可以在一次轮询中获得所有的消息。然而，即使这个主题有更多的信息，在一次呼叫中，民意调查只返回几千条信息(大约6000条)。< br> 如何进一步增加单个消费者阅读的邮件数量？

我希望编写一个Azure函数，该函数接收来自IoTHub的消息，并根据消息中的数据将其放置在服务总线队列中。问题是，队列名称将根据我所查看的消息和留档的参数进行更改，例如，将队列名称设置为输出设置的一部分。有人做过类似的事情吗？或者有任何代码示例可以根据传入消息中的值写入队列？我试图设置一个函数，但它甚至不让我设置输出类型为服务总线，而不把队列名称，我不能，因为它是不固定的！ 所以如果输入是： 函