我需要定期读取mongo DB表数据，并使用spring boot将其发布到Kafka主题中。我在Mongo DB中创建了一个集合，并在Mongo DB中插入了一些记录。此外，我希望定期从Mongo DB读取数据，并需要使用spring boot在Kafka的主题中发布这些表数据。我是spring batch scheduler的新手。
浏览 22提问于2020-10-02得票数 0
我正在尝试使用Spring Boot在Kafka中创建一个新主题。.partitions(topic.getPartitions()) .build();} 但是我不能使用Spring Boot REST POST调用来实现以下内容。{ }
/&
浏览 104提问于2021-07-12得票数 1
回答已采纳
1回答
如何阅读来自Kafka topic on demand的消息。我有主题名称，offsetId，PartitionID，使用这三个参数，我如何从Kafka主题中检索特定的消息。可以使用Spring Kafka吗？我使用的是spring boot 2.2.4.RELEASE
浏览 0提问于2020-11-10得票数 0
我有一个项目，其中使用Spring Boot相关项目。我想在项目中使用Kafka的消费者和生产者的事务功能。我需要尽可能高效地在Kafka中产生大量的消息。如何使用Spring boot开发多线程消费者和生产者？
浏览 81提问于2020-10-14得票数 0
回答已采纳
我正在尝试基于@KafkaListener注释创建自定义元注释，但是spring-kafka抛出了一个错误。(SpringApplication.java:360) [spring-boot-1.5.4.RELEASE.jar:1.5.4.RELEASE]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:303) [spring-boot-1.5.4.RE
浏览 0提问于2017-12-13得票数 1
我的Spring boot项目有4个模块，我需要使用Kafka在模块之间建立通信。我在我的电脑上安装了Kafka，并使用cmd创建了主题。问题是，在我提交我的项目后，除非我的老师在他的计算机上创建了相同的主题(根据我所理解的)，否则主题将不起作用。 有没有办法确保我的项目自动创建主题？
浏览 244提问于2021-10-14得票数 0
回答已采纳
我的要求是，当应用程序无法处理从通过spring boot java应用程序使用的kafka主题的当前偏移量读取的消息时，重置kafka主题的偏移量。在手动重置偏移量或发送否定确认之后，需要通过spring boot java应用程序的kafka消费者再次从不合适的偏移量值轮询消息。它能实现吗？
浏览 3提问于2019-01-09得票数 1
我有一个使用Kafka的spring boot项目。我配置了Spring Cloud Stream Kafka自动配置。我想创建我的主题自动与3个副本和1天的保留。为此，我在application.yml中添加了复制因子和retention.ms，如下所示： cloud: kafka: pro
浏览 10提问于2021-03-11得票数 0
回答已采纳
我在consumerFactory和producerFactory bean中使用Spring。我知道我可以使用spring自动配置。但我采用了这种方法。在这种方法中，我使用死信主题作为错误处理程序。当我使用autoCreateTopics = "true"和启动应用程序时，它首先尝试从KafkaAdminClient捕获配置。当应用程序启动时，它首先尝试使用KafkaAdminClient中定义的引导服务器，即127.0.0.1
浏览 6提问于2022-08-25得票数 0
回答已采纳
1回答
我正在使用以下包来消费kafka消息 compile 'org.springframework.boot:spring-boot-starter-webflux'// tag::actuator[]
compile("org.springframework.<em
浏览 7提问于2019-05-15得票数 0
回答已采纳
我们目前正在尝试创建一个SCS应用程序，该应用程序可以生成特定的主题消息，但是在运行该应用程序时，我们遇到了错误： The following method did not exist:
org.springframework.kafka.core.DefaultKafkaProducerFactory.setBeanName我们认为spring-boot和SCS之间存在兼容性问题。我们使用的是spring-boot版本: 2.2.2-REL
浏览 109提问于2020-07-22得票数 1
回答已采纳
1回答
Kafka未连接到下面的问题
、、、、
=localhost:9092spring.kafka.consumer.auto-offset-reset=earliestspring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consume
浏览 7提问于2021-09-09得票数 1
我正在尝试使用以下代码在动态创建的主题上发送消息：public class KafkaMessageSender { LOGGER.info("sent payload to topic='{}'", topicName);}
当我使用topic = 'somethingnew‘调用这
浏览 12提问于2018-02-13得票数 3
回答已采纳
1回答
每当试图运行我的spring引导Kafka应用程序时，我都会得到以下错误。(SpringApplication.java:1226) [spring-boot-2.3.1.RELEASE.jar:2.3.1.RELEASE] ... 15 common frames omitte
浏览 6提问于2020-08-04得票数 0
回答已采纳
我有一个应用程序是基于spring boot，spring-kafka和kafka-streams。当应用程序启动时，它使用默认的主题列表创建kafka streams拓扑。我需要做的是在运行时编辑/重新创建拓扑。例如，当应用程序已经运行时，有一个新的主题名称出现，我想将此主题添加到我的拓扑中。目前我正在考虑以某种方式删除现有的拓扑，关闭并清理KafkaStreams，运
浏览 16提问于2020-04-11得票数 1
回答已采纳
我正在使用Kafka设置一个基本的Spring Cloud Stream producer。其目的是接受HTTP POST，使用Spring Data JPA将post的结果保存到数据库，并使用Spring Cloud Stream Kafka Binder将结果写入Kafka主题。──┐
| kafkaTransactionManager defined in com.example.tx.Application
浏览 25提问于2021-07-01得票数 0
回答已采纳
3回答
plugins { id 'java' 'org.springframework.boot:spring<
浏览 15提问于2019-05-08得票数 0
回答已采纳
我正在使用camel-spring-boot-starter中的camel- kafka ，在spring引导项目中将一条消息从一个卡夫卡主题路由到另一个。在某些主题上，我当前的应用程序，它只使用、camel-kafka、和(没有弹簧云流)。
在骆驼中，我们使用urls提供..。有点像. uri(kafk
浏览 2提问于2018-06-20得票数 0
我一直在尝试使用Kubernetes在本地使用模式注册表部署Kafka。为了在本地运行Kubernetes，我使用了Kubernetes版本v1.13.0的用户Minikube版本v0.32.0apiVersion: v1 name: kafka-1 ports: port: 9092 app: kafka</
浏览 1提问于2019-01-18得票数 9
1回答
我需要使用java高级rest客户端api将这些日志索引到elasticsearch。是否有任何将日志索引到elasticsearch的有效方法?
浏览 6提问于2021-08-04得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
