有几个实现HealthIndicator的示例需要KafkaTemplate。我实际上并不手动创建KafkaTemplate，但HealthIndicator需要一个。有没有办法自动获取创建的KafkaTemplate (使用application.yml配置)？这与在新创建的consumerFactory中手动创建已存在于application.yml中的重复配置相比。
浏览 16提问于2021-03-13得票数 0
回答已采纳
是否有一种方法可以使用注释驱动代码来实现下面代码的行为？KafkaProducerMessageHandler<String, String> handler = handler.setSendFailureChannel(failure());}
public K
浏览 1提问于2018-12-19得票数 1
回答已采纳
2回答
我正在开发一个spring引导应用程序，这个依赖库仅用于消费数据并将数据推送到数据库。
卡夫卡( spring-cloud-stream-binder-kafka )或卡夫卡(spring)
浏览 9提问于2022-04-27得票数 -2
我试图在kafka流(Kafka 1.0.1)和spring云流(2.0.0-构建快照)的帮助下实现一个简单的事件源服务。我的StreamListener方法只是读取与聚合状态变化相对应的事件流，并将它们应用于聚合，并将最新的状态保存在本地状态存储中(kafka提供了状态存储)。域事件消息还具有与聚合的uuid(String)相同的键。Update:可能不再需要了
浏览 0提问于2018-04-07得票数 1
回答已采纳
读取工件我的问题是，如果jar包含KafkaTemplate.class 而不是在类路径中，那么spring是如何在自动配置过程中执行以下代码的。或者spring在自动配置时根本不会执行这个操作？)
public KafkaTemplate<?<Object, Object> kafkaProducerListener
浏览 0提问于2019-02-18得票数 1
回答已采纳
1回答
来生成correlationIds / traceIds，当使用HTTP与其他服务对话时，它们会被保存下来，从而使我们能够在各种微服务的日志中跟踪给定的ID。当我能够获得当前的traceId并将其插入到我的DTO中时：private Tracer tracer;
private RabbitMessageDto createRabbitMessageWithPayload谷歌一直在给我介绍春季云流和春季云</
浏览 1提问于2017-08-17得票数 1
回答已采纳
2回答
我正在构建一个Spring Boot 2.4.4应用程序，使用模式验证向Kafka (Confluent Platform)生成消息。该模式是在该主题的模式注册表中设置的，我已经使用Maven Avro插件从相关的AVSC文件创建了POJO (LoanInitiate)。.send(topic, message); //"Unsupported Avro type"
<
浏览 293提问于2021-04-23得票数 1
我正在探索Spring (spring-boot-starter-parent版本2.7.4)，我在消费者中发现了一些奇怪的行为，并使用了标准的@KafkaListener注释。我用KafkaTemplate生成消息并添加自定义的报头支柱__ProducerApp__，但是我也有标准的标头支柱__TypeId__，因为它是由Spring实现自动添加的。> kafkaTemplate</
浏览 17提问于2022-10-08得票数 0
1回答
我有一个使用spring引导云和apache的项目，我有一个涵盖拓扑逻辑的集成测试列表，多亏了EmbeddedBroker。
我最近发现，在运行这些测试时，日志中有许多噪声。经过一些尝试和错误之后，这些似乎是由春云流绑定创建的生产者。以某种方式，在类级别上使用@DirtiesContext(classMode =classMode)，它们似乎在每次测试后都不会被清除。因此，我想，如果我能够访问生产者工厂，那么我就可以在我的测试类的@AfterEach子
浏览 3提问于2021-03-11得票数 0
回答已采纳
我是否需要自己在主服务器上安装Spring数据流实例，还是将其作为部署的一部分“自动”安装？我遵循了指南，尽管删除了MySQL的所有配置。也许这是必需的。虽然我有点卡住了，因为它只是没有分配外部IP，我不知道为什么，如何调试，以及我是否错过了安装一些必要的组件。
编辑:为了澄清，我在运行时看到一个scdf服务条目。
浏览 13提问于2016-11-20得票数 0
1回答
我有一个带有几个模块(父模块、服务模块、updater1模块、updater2模块)的多模块maven项目。@SpringBootApplication在“service”模块中，其他模块没有工件。我想用testcontainers在这个模块中创建集成测试，所以我已经创建了容器和一个Kafka生产者来向我的消费者发送一个KafkaTemplate。我的问题是Kafka生成器自动设置为空，所以测试抛出了一个NullPointerException。我认为
浏览 17提问于2021-04-29得票数 0
回答已采纳
我正在使用springboot并尝试编写一个KafkaProducer来推送Kafka队列中的消息。我在@Configuration类中创建了这些方法。类中自动连接了这个KafkaTemplate bean，它负责处理KafkaTemplate的发送函数。@Autowired但是当我试图编译我的代
浏览 3提问于2020-09-09得票数 0
我正在试图找到spring云流的示例，在那里它为RMQ创建了基于parition的生成器。我想看看它将如何为这些队列创建绑定，因为RMQ本机不支持主题的定义，但是它将创建数量相当于分区数的队列(我看过了，可能是错的)。首先，我想了解如何使用RMQ上的spring云流为基于分区的生产者创建生产者。
浏览 1提问于2017-04-25得票数 2
回答已采纳
1回答
我有一个spring引导应用程序，它让使用者从一个集群中的主题消费，然后在不同的集群中生成另一个主题。现在我正在尝试用spring编写集成测试用例，但是有一个KafkaTemplate could not be registered.",pro);在我的测试用例中，我希望覆盖KafkaTemplate，以便当我在Test中调用kafkaConsumerService.pr
浏览 0提问于2019-02-18得票数 1
回答已采纳
基本上，我需要拦截云流的@Input和@Output注释的用法。这是自动向每个ChannelInterceptor添加特定MessageChannel所需的。(无论消息是生成还是使用，preSend方法中的行为都会略有不同)。2.0.1中非常好，但对于Spring 2.0.2则不行，我很难理解其中的原因。我还没有尝试过其他云流的
浏览 3提问于2018-06-04得票数 1
回答已采纳
我有一个Spring boot应用程序，它使用来自Kafka主题的数据并用从Kafka接收的数据发送电子邮件通知，public EmailService emailService() {EmailServiceImpl(getJavaMailSender());它工作得很好，但是在我添加了@ConditionalOnBean之后@ConditionalOnBean(KafkaTemplate.classEmailService emailService() {
return new
浏览 4提问于2021-08-11得票数 1
我有两种不同的服务
第二服务将从上面的kafka主题-1中侦听，并将其写入另一个kafka主题-2(在该主题中，没有手动提交、启用事务以生成其他主题、自动提交偏移量设置为false & isolation.level设置为read_commited)，我们将动态标识主题名，因此我们使用动态目标解析器。:351) ~[spring-kafka-2.2.0.RELEA
浏览 1提问于2019-04-03得票数 1
回答已采纳
共提供3种不同的服务
第三，服务将从KafkaTop-2中侦听，并将其写回Solace队列(在该队列<
浏览 0提问于2019-03-29得票数 1
回答已采纳
1回答
我使用的是春云启动流卡夫卡库，我有以下卡夫卡制作人 private KafkaTemplate<byte[], byte[]> template;
@Autowiredspring.cloud.stream.bin
浏览 1提问于2020-02-05得票数 0
1回答
我有一个spring cloud项目，它具有以下打包结构
我想通过调用控制器发布的端点来执行集成测试。问题是目前我没有feign客户端访问的端点(原始和spring云合约存根都不可用)。
在这种情况下，如何将feign客户端发出的调用存根。
浏览 0提问于2018-04-23得票数 1
云服务器
ICP备案
对象存储
腾讯会议
云直播
腾讯云开发者
