《中邮消费金融》专题

目前，我有一个Flink集群，它想通过一个模式消费Kafka主题，通过使用这种方式，我们不需要维护一个硬代码Kafka主题列表。 --update--我需要知道主题信息的原因是我们需要这个主题名称作为参数，在即将到来的Flink sink部分中使用。

知道为什么当server0关闭时，即使主题test1的复制因子设置为2，使用者仍然停止获取消息吗？ 已经有一个类似的问题，但它没有完全回答Kafka0.10快速入门：当“主要”经纪人被扳倒时，消费者失败

我有一个Kafka消费者。好像工作了一段时间，然后就死了。它重复这样做。我得到了这个异常，但没有其他信息。 305000毫秒是5分钟。有什么线索可能导致这种情况吗？或者尝试找出答案的步骤？ 如果相关： 我在不同的机器上有3个进程，使用最新的JavaKafka客户端版本0.10.2.0。每台机器运行20个线程，每个线程都有一个单独的消费者。根据设计，当一个线程死亡时，所有线程都被杀死，进程死亡，然后

我有一个项目，使用了DLQ方法，在< code>@KafkaListener的任何异常中，错误将被发送到一个具有< code>error-结构的主题 这样，我们可以重试特定使用者组的消息。消息处理程序从主主题和重试主题中读取。 由于项目中有多个侦听器都使用相同的容器，因此我们将主题（主侦听器、错误侦听器和重试）放在应用程序属性中，并配置以查找相应的 DLQ（注意，这是 Kotlin）： 这一切都很

我已经使用Spring Kafka创建了一个Kafka消费者，并将其部署在云铸造中。该主题有10个分区。我计划将应用程序扩展到10个实例，以便每个实例可以使用来自一个分区的消息。Spring Kafka支持并发消息侦听器容器，我猜它支持从每个分区创建多个线程来使用。例如，如果我有5个消费者实例，每个消费者实例可能有2个线程从分区消耗。因为我计划为每个分区创建一个应用实例，所以使用并发消费者有什么好

这两个队列运行在同一个EMS服务器上。有些人对这种配置有看法：只使用一个ConnectionFactory就可以配置它们，两个实例不是必需的。但是，如果我使用一个ConnectionFactory实例，那么该实例将同时用于DefaultMessageListenerContainer和CachingConnectionFactory（进一步用于JmsTemplate）。我不知道他们是否互相影响。

我为Kafka建立了一个docker形象（Wurstmeister/Kafka-Docker）。在docker容器中，我可以使用内置的shell脚本创建主题、生成消息和使用消息。现在，我使用https://github.com/mapr-demos/kafka-sample-programs托管的代码从我的主机连接到kafka broker。在构建和运行程序之后，什么都没有发生，程序就会堆积起来。

由于某种原因，当我试图使用SDK授权PayPal支付时，我的日志中不断出现以下错误： 错误：访问https://api.sandbox.paypal.com/v1/payments/payment时获得Http响应代码400。{“name”：“validation_error”,“details”：[{“field”：“Transactions[0].amount”,“Issue”：“Transa

我想了解消费者信息处理尝试间隔时间的限制。例如，假设我有以下AWS资源 SQS队列（名为SQSQueueName1）w/reDrive配置为发送死信消息到SQSQueueName1DLQ SQS队列DLQ（名为SQSQueueName1DLQ） Lambda函数（名为LambdaName1） 如果SQSQueueName1有一个重置策略，MaxRecieveCount设置为10，在这种情况下，消费

我有一个spring cloud stream Kafka消费者服务，其中确认是手动完成的。提供了一个固定的用户组。 spring.cloud.stream.bindings.input.group RESETOFFSET和startOffset属性的设置如下所示。云流动Kafka。绑定。输入消费者resetOffsets=真实Spring。云流动Kafka。绑定。输入消费者STARTOFSET=

我已经通过Docker compose运行了Kafka和Zookeeper。我可以使用Kafka终端向主题发送/使用消息，也可以通过Conduktor监控所有内容。但不幸的是，我无法通过使用阿尔帕卡连接器的Scala应用程序使用MSG。该应用程序连接到主题，但每当我向主题发送MSG时，都没有任何反应。 只有Kafka和动物园管理员正在通过码头工人组成运行。我直接在主机上运行 Scala 消费者应用

假设主题分区的高水印是1000和领导者，所有追随者副本都有完全相同的消息。在此场景中，生产者发送一条带有的消息，使用者正在使用此主题。这里是否存在这样一种可能性，即消费者提取请求将在其他副本提取请求之前得到服务？ 这是因为在我们的设置中，在情况下，消费者在关注者之前收到了一条消息。

下面我用一篇关于临时排队的文章来解释我的想法，我只想知道我对还是错。 参考链接：如何使用JMS实现请求响应 “创建临时目的地、消费者、生产者和连接都是与代理同步的请求-响应操作，因此在处理每个请求时应避免，因为它会导致与JMS代理进行大量聊天。” 我不明白这句话在咒骂什么？在不同的线程中我们可以访问临时队列吗？一点道理都没有？有人能解释一下吗

我正在使用SpringCloudStream进行消息传递。在消费者部分，我使用IntegrationFlow来监听队列。它正在监听并打印来自制作人的信息。但格式不同，这是我现在面临的问题。生产者的内容类型是application/json，IntegrationFLow消息负载显示ASCII数字。下面给出了为消费者编写的代码 输入接口是， 消费者的yml配置是， 我试过了。类绑定，那一次我从队列中

我有多个数据库，都包含同一个表。我想从中读取，将所有元素输入到方法中，并写回该方法的输出。 然而，我需要bean中元素来自哪个源的信息（例如持久性单元的名称）以进行验证。最好的方法是什么？