《中邮消费金融》专题

问题内容： 我需要编写一个类似于生产者- 消费者的问题，必须使用信号量。我尝试了几种解决方案，但都无济于事。首先，我在Wikipedia上尝试了一个解决方案，但没有成功。我当前的代码是这样的： 使用者的方法运行： 生产者的方法运行： 在上面的代码中，发生了一个消费者线程读取一个位置，然后另一个线程读取了相同位置而没有生产者填充该位置的情况，如下所示： 问题答案： 似乎您使用的是互斥锁而不是信号灯？

我尝试在使用邮件时进行以下错误处理： 如果出现序列化错误：在DLT中发送消息 我拥有的（2.5.1Kafka客户端的Spring kafka 2.5.5版本）如下： 现在，如果我发送不可序列化的消息，我的消息将不重试地发送到DLT- 在我的中，我有一个，捕获并重新捕获。 我应该没有重试，但我得到了2个重试，每个20秒（而不是10秒？），并在2次重试后向DLT发送了一条消息。 如果我删除errorH

以下代码可以是自定义请求/响应实现的一部分。我没有使用EventBus。请求，因为我需要更多的自由，比如对一个请求发送多个响应。 问题是：我真的必须等待完成处理程序，还是可以像这样简化代码？ MessageConsumer的Javadoc。completionHandler描述了此方法在“注册已在集群中传播”时通知给定的处理程序。因为没有使用EventBus的集群。localConsumer，是否

我在这里设置了一个最小的示例，其中有N个Kakfa主题的N个流（在下面的示例中为100个）。 我想在每个流看到“EndofStream”消息时完成它。当所有流都完成时，我希望Flink程序能够顺利完成 当parallelism设置为1时，这是正确的，但通常不会发生。 从另一个问题来看，似乎并非Kafka消费群体的所有线索都结束了。 其他人建议抛出异常。但是，程序将在第一个异常时终止，并且不会等待所

我正在为一个简单的Spring Boot应用程序编写Kafka联调。该应用程序简单地发布到Kafka主题。 我正在使用一个嵌入式Kafka实例进行测试。当通过Intellij运行时，测试运行得非常好，但当我通过gradle运行时，测试失败。看起来好像倒计时从未达到0，测试最终超时。 生产者配置： 制片人： 消费者： 测试： application.yml： 知道问题出在哪里吗？

Spring的云流是否也支持Kafka式的动觉再平衡？最近有人promise要解决这个问题https://github.com/spring-projects/spring-integration-aws/issues/99 谢谢

我有一个使用Spring kafka库的Spring启动应用程序的消费者。我想为每个消费者线程设置租户上下文，即在创建每个线程时调用一个方法（创建时每个线程只调用一次）。目前，我已将其添加到listner中，其中对方法有@KafkaListner注释，但它每次轮询并处理每条记录时都会调用它。我想在消费者线程启动时调用此方法一次。如果我们有任何这样的事情，请在这里帮助我。

我正在使用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文件，我的部署管道将其推送到单个实例。使用我的部署管道，我可能可以将此工件部署到我的部署池中的多个实例。 但是，当我希望多个消费者作为我的基础设施的一部分时，我无法理解以下内容- > 实际上，我可以在部署池中定义多个实