《中邮消费金融有限公司》专题

我正在使用Spring boot2.1.7。RELEASE和spring-kafka 2.2.7。RELEASE。我正在使用@KafkaListener注释来创建一个消费者，我正在使用消费者的所有默认设置。 这是我的消费者配置： 由于某些原因，我在同一个应用程序中有多个使用者，如下所示。 尽管如此，根据关于“消费者线程安全”的合流文件 一个线程中不能有多个属于同一组的使用者，也不能有多个线程安全地

我有一个spring boot服务，它使用Kafka主题。当我消费时，我会对Kafka信息执行某些任务。在执行这些操作之前，我需要等待服务将一些数据加载到我设置的缓存中。我的问题是，如果我将kafka consumer设置为autostart，它将在缓存加载并出错之前开始使用。 我试图在加载缓存后显式启动使用者，但却出现空指针异常。 Kafka利斯泰纳 要启动和停止的服务 主要方法 以下是例外情况

我试图在我的spring boot项目中使用spring kafka来阅读来自我的kafka的消息。我正在使用@KafkaListener，但问题是我的消费者总是在运行。只要我从控制台生成一条消息，它就会在我的应用程序中弹出。我想定期投票。我怎样才能做到这一点？ } 这是我的消费者配置：

我已经做了一些Kafka流应用程序和Kafka消费者应用程序。最后，Kafka流不是什么，而是消费来自Kafka的实时事件的消费者。所以我不知道什么时候使用Kafka流，或者为什么我们应该使用Kafka流，因为我们可以在消费者端执行所有转换。

我想配置一个将绑定到多个主题的使用者应用程序（将在一个JVM上运行）。 使用者应用程序中的每个“consume”（假设我有两个主题要侦听）方法将使用@StreamListener注释设置，并链接到特定的主题。 我还将在不同的使用者组中配置每个使用者。 在这样的配置中，使用者应用程序将如何表现？ 消息将一个接一个地发送？ 我需要在不同的线程中实现每个listner？ 这种方法是否有效？ Kafka版

应用程序通过在服务的独特使用者主题中生成消息来查询服务。 查询消息由报头和有效载荷组成。除其他外，头包含应该在其中产生响应的主题信息。 服务生成响应并将其发送到完成请求周期的应用程序使用者主题。 考虑到响应必须始终到达负责请求的应用程序实例，在主题名称和分区复制方面，什么是最好的方法？

Kafka在docker容器里工作得很好。我可以使用并成功地创建主题、生成/使用消息，但是当我使用本地kafka脚本从docker容器外部尝试时，我只能创建和列出主题。生成和使用消息会引发错误： 生产： 消耗： 这是我的DockerFile： 脚本/start-kafka.sh

我编写了一个Kafka消费者（使用Spring Kafka），它从单个主题读取并且是消费者组的一部分。一旦消息被消费，它将执行所有下游操作并继续下一个消息偏移量。我已将其打包为WAR文件，我的部署管道将其推送到单个实例。使用我的部署管道，我可能可以将此工件部署到我的部署池中的多个实例。 但是，当我希望多个消费者作为我的基础设施的一部分时，我无法理解以下内容- > 实际上，我可以在部署池中定义多个实

Camel RabbitMQ的新手。用Apache Camel写了一个简单的RabbitMQ消费者。 当前在从队列中弹出一个值后进行一个简单的rest调用。它可以处理大约100条消息，并开始抛出此错误 我不确定我做错了什么，任何帮助都是感激的。

我正在编写一个概念验证应用程序来使用Apache Kafka0.9.0.0中的消息，看看是否可以使用它而不是通用的JMS消息代理，因为Kafka提供了好处。这是我的基本代码，使用新的消费者API： 我使用默认设置启动了一个kafka服务器，并使用shell工具启动了一个kafka生产者，以便将消息写入我的主题。然后，我使用这段代码与两个使用者连接，发送正确的服务器来连接，发送主题来订阅，其他一切都

我使用分布式jms队列，weblogic是我的应用服务器。在我的集群环境中部署了三个jms服务器。例如，生产者只是使用队列名称jndi lookup 'udq '来发送消息。现在，我已经为每个jms服务器关联了一个消费者，并且能够消费消息，到目前为止没有问题。 这里有一个问题，我是否可以让一个消费者使用来自3个jms服务器的消息。weblogic允许使用以下语法对目标查找进行jndi命名：@ 我只

我编写的库使用中的，应用程序本身也使用。 使用Gradle4.7。在第4.4.1节中也面对这一点。 怎么修？ 项目格拉德尔 app.gradle 迈里布。格拉德尔 从

我们有一个kafka streams应用程序（2.0），它正在与kafka代理（1.1.0）通信。streams应用程序一直在毫无原因地重新处理整个日志-应用程序没有重新启动，没有重新平衡，只是闲坐着-在某些情况下，它正在处理消息，在另一些情况下，它正在等待接收消息（处理消息的时间不到6个小时）。我们已经做了大量的研究，通过将

我们有一个具有Ha all策略的2节点RabbitMQ集群。我们在应用程序中使用Spring AMQP与RabbitMQ对话。生产者部分工作正常，但消费者工作了一段时间并暂停。生产者和消费者作为不同的应用程序运行。更多关于消费者部分的信息。 我们将与一起使用，使用手动模式和默认 在我们的应用程序中，我们创建队列（按需）并将其添加到侦听器中 当我们从10个和20个开始时，消费大约持续15个小时并暂停

尝试在主题使用者上实现持久功能。为 jms 使用者和客户端 ID 放置了一个名称。（显然添加了持久=“真”） 据我所知。当它第一次运行时，该主题会将消费者注册为“耐用”。 所以基本上我这样做了，部署了生产者和消费者。它被注册为耐用消费者。将消息发布到主题，消费者将获得消息。现在，我取消部署消费者，并发布另一条消息，消费者无论何时起床都应该收到。当我再次部署消费者时，我得到了通用的temp-topi