我刚刚开始使用Spring boot RabbitMQ。我想知道在spring boot rabbitmq (注解配置)的情况下，我们如何分别配置生产者代码和消费者代码。我的意思是，如果我想在spring boot中编写rabbitmq生产者代码，用python编写消费者代码，或者反之亦然-在spring <e
浏览 2提问于2018-03-25得票数 0
我已经设置了一个Spring Boot应用程序来接收来自现有的和工作的Kafka生产者的Kafka消息。控制台消息在以下链接中进行了讨论：当第一个问题得到解决时，超时很可能不会发生。给出的控制台消息的解决方案是显式地将--security-protocol SSL作为参数传递给生产者或消费者命令。
假设我正在监听一个现有的Kafka代理和主题，在那里不能更改任何设置。任何更改都必须在
浏览 11提问于2018-02-09得票数 2
我们正在使用spring boot将我们的项目迁移到微服务。我有一个需求，我应该能够使用配置细节运行生产者和消费者，比如引导服务器和用户在运行时提供的键值serdes。在之前的项目中，我可以使用java Apache Kafka API来实现这一点，但我看不到使用spring-kafka API的任何方法，因为它只允许通过Spring java配置类或application.properties来定
浏览 14提问于2021-05-25得票数 1
我刚接触docker，在Docker容器中运行Kafka代理时遇到了问题。我和kafka开发了spring boot应用程序，生产者和消费者在同一个应用程序中。应用程序在没有docker的情况下成功运行，但当我尝试通过主机上的docker容器运行它时，会出现以下错误：
org.apache.kafka.clients.NetworkClient
浏览 237提问于2021-02-21得票数 0
1回答
但是，我不能在Prometheus中使用生产者和消费者指标。这些客户端指标必须由生产者和消费者导出吗？
Kafka broker的指标可用。有什么遗漏的东西吗?
浏览 12提问于2021-09-02得票数 0
我有一个运行在服务器上的RabbitMQ消息代理，我正在尝试使用配置一个生产者和一个消费者。我的生产者每秒钟都在队列中创建消息，而我的使用者以相同的速度读取它们。但是，如果我停止了我的使用者，而生产者一直在推消息，当我再次重新启动我的使用者时，它将无法检索在它被关闭的那一段时间内创建的消息，只会收集从启动时产生的消息。当队列启动时，如何使我的使用
浏览 0提问于2020-10-16得票数 0
回答已采纳
我有一个Springboot服务，它成功地消费了一条来自kafka主题的消息。作为进一步开发的一部分，我需要将消息发布到同一消费者服务中的另一个kafka主题，该主题是以前创建的，运行良好。但是当我介绍一个Kafka生产者配置时，它在消费者配置中给出了错误，如下所示 WARN | [main] | org.springframework.context.support.AbstractAppli
浏览 225提问于2021-09-29得票数 0
1回答
现在我想为我们的系统开发一个通用的邮件服务。在我们设计时，我们想要开发一个RabbitMQ生产者和消费者。在消费者端，我们可以开发和部署Spring Boot或Spring Cloud应用程序，但在生产者端，我们希望提供一个通用的邮件客户端，如下面的接口，并为其他系统建立一个jar依赖。interface MailClient {
ListentableFuture send(Message m
浏览 46提问于2015-09-21得票数 56
回答已采纳
1回答
我有一个spring boot kafka消费者和一个spring boot kafka生产者，当我在终端中启动消费者并在启动生产者之后，消费者收到数据时，如果且仅当我按下任何键盘键时，我不知道为什么这是我的配置。
浏览 37提问于2020-04-15得票数 0
在没有Spring Boot自动配置功能的情况下，是否可以仅将spring-kafka用作配置框架-类似于解析application.properties或application.yaml，并实例化消费者和生产者基本上，只为public static void main应用程序提供了最少的spring和spring-kafka。
谢谢
浏览 12提问于2020-03-04得票数 0
回答已采纳
我有生产者和消费者春云流应用程序，我们不知道我们将启动哪个应用程序first.either，它可以是生产者还是消费者。当我们在application.properties中为生产者和消费者应用程序声明有关目标(Exchange)、组(队列)的属性时，如果目的地(Exchange)、组(队列)已经存在，请不要再次尝试创建--使用现有的--否则<em
浏览 1提问于2018-12-11得票数 0
回答已采纳
但是，我的Kafka实例不在本地，由我公司的基础架构团队管理，因此它在远程服务器上运行。我有运行它的地址和端口，但我不确定如何配置我的应用程序以连接到它。spring.kafka.bootstrap-servers=[kafka-server-1:port],[kafka-server-2:port]spring.kafka.security.protocol=SSL
在我为
浏览 54提问于2021-11-09得票数 1
我有两个spring boot rest服务。一个是json内容的生产者，另一个是消费者。ResponseEntity<Cars> resp = new ResponseEntity<Cars>(cars, respHeader, HttpStatus.OK);在使用者spring boot服务代码中，我使用resTemplate来调用这个端点并获得结
浏览 3提问于2018-04-25得票数 0
我有一个基于Reactor的Spring Boot Kafka流处理应用程序，我正在为它编写集成测试。我使用的是Spring的@EmbeddedKafka代理。它工作得很好，我让它覆盖了在我的反应式处理器的消费者和发布者上配置的引导代理urls，但我还没有弄清楚的是在测试时如何处理我的处理器的模式注册表。我使用的是Confluent的KafkaAvroSerializer和KafkaAvroDeserializer类，只是在<
浏览 38提问于2020-12-17得票数 0
我正在尝试配置一个Soap客户端，以便在Spring boot (java)中使用来自智能卡的证书进行身份验证。
浏览 0提问于2020-11-22得票数 1
1回答
缺少Kafka生产者jmx指标
、、、、
我们有Spring Boot应用程序部署在开放源码开发环境( Kubernetes的原始社区发行版，支持Red )上。在没有经过devops团队太多调整的情况下，我们从kubernetes-service-endpoint exporter工作中获得了prometheus抓取的kafka消费者指标，以及一些生产者指标，但只针对kafka connect api，而不针对标准kafka生产者api。我猜这是该作业的配置
浏览 1提问于2019-11-17得票数 1
在我们的一个基于spring-boot的服务中，我们打算同时连接到两个不同的kafka集群。这些集群每个都有自己的一组引导服务器，主题配置等。它们之间没有任何联系，就像this question中的情况一样。 我将在不同的主题名称上从每个集群读取不同类型的消息。可能有也可能没有多个生产者从这个服务连接到两个集群，但我们肯定每个集群至少有一个消费者。我想知道如何在application.yml
浏览 25提问于2020-07-27得票数 1
回答已采纳
我有两个独立的应用程序，一个是生产者，另一个是exchange类型默认(直接)的使用者。 // TODO Auto-generated method stub
现在，当我运行使用者服务时.deadLetterRoutingKey(env.getProperty("dle.routingkey"
浏览 8提问于2021-10-10得票数 1
回答已采纳
1回答
我正在创建一个支持Kafka的Spring Boot应用程序。我已经创建了一个生产者和一个消费者，一切都像魔咒一样工作。在运行时，我有一个消费者。我想要有许多消费者，我的主题有相同数量的分区。如何创造更多的消费者？ 我一直在搜索文档，但没有成功。 谢谢！
浏览 16提问于2019-07-03得票数 0
回答已采纳
1回答
需要配置Spring使用者连接池吗？我在spring引导应用程序中只有一个消费者(作为一种微服务)，生产者在另一个应用程序中。下面的内容让我有点困惑：(摘自)
注意:虽然PooledConnectionFactory确实允许创建一个活动消费者的集合，但它并不是“池”使用者。池对于连接、会话和生产者来说都是有意义的，因为这些资源很
浏览 0提问于2017-12-08得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
