1回答
spring: producer: "schema.registry.url": http://schema-registry.com:8081environment:
- SPRING_KAFKA_PRODUCER_PROPERTIES_SCHEMA.REGISTRY.URL=http://schema-registry.com
浏览 2提问于2021-03-11得票数 1
回答已采纳
我是Spring和Kafka的新手。我正在做一个使用SpringBoot-kafka的用例，允许用户在运行时创建kafka主题。spring应用程序期望在运行时以编程方式订阅这些主题。到目前为止，我所知道的是，Kafka listener是设计时，因此在启动之前需要指定主题。有没有办法在SpringBoot-Kafka集成中动态订阅kafka主题？已引用此
我计划实现的当前方法是，不要使用Spring-Kafka集成，而是自己使用这里
浏览 0提问于2017-01-08得票数 11
2回答
> <artifactId>kafka_2.11</artifactId>-- https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients -->
<dependency><
浏览 4提问于2020-03-24得票数 3
回答已采纳
我有一个简单的，它现在什么也不做，它只是一个简单的Spring Boot 2应用程序，应该使用java 9。ERROR] Failed to execute goal org.springframework.boot:spring-boot-maven-plugin:2.0.0.M5:repackage (default) on project hero-journey-web: Execution default of goal org.springframework.boot:spring
浏览 5提问于2017-10-15得票数 4
回答已采纳
尝试使用Springboot-Kafka进行实践。有几个疑问。这些参数对于application.yml中的Kafka调优有效吗 fetch-max-bytes: 52428800 你知道这是不是Kakfa上的有效属性？我在我的springboot项目中的application.yml中使用它来控制我的消费者轮询行为。其次，在此块中是否存在由KafkaListener内部启动的多个线程 @KafkaListener(id = "instance1", groupId = "${spring.<
浏览 55提问于2021-08-05得票数 0
回答已采纳
在其中一个例子中，当消费者服务重新启动时，它会导致重新处理发送给Kafka的所有记录。Kafka Broker: 0.10.0.1Kafka Consumer SpringbootService: Springboot version 2.2.0.Release
现在，为了研究这个问题，我想在开发/本地环境中重新创建这个场景，这个场景不会发生！有
浏览 3提问于2020-07-10得票数 0
我的系统管道是"IBM队列-> Springboot app (消息格式化程序) --> Kafka topic-1 (消息队列) --> Springboot app (消息转换器)-> --> Kafka目前还没有实现Dynatrace监控，但是这里使用了用于Kafka监控的汇合控制中心。您能否建议一些可能的选项来度量Springboot应用程序处理的消息的个人和端到端处理时间(通过DevOps Jenkins管道部署消息格式化程序和消息转换器
浏览 5提问于2019-11-26得票数 0
回答已采纳
对于Springboot 1.5.x / Spring Kafka 1.3.x部署的Kafka容器工厂，是否有类似的功能？Lazy注解是否适用于@KafkaListener，@Configuration类的Kafka配置或类似的组件类？当使用Springboot 1.5.x时，在Springboot 2.1.x (或更高版本)和兼容这些版本的Spring Kafka版本中，这是如何变化的(如果有)？
浏览 0提问于2019-10-29得票数 1
我想使用kafka和springboot实时地从文件中发送数据，我已经测试了这个代码，用postman以JSON格式将数据发送到kafka主题。void order(@RequestBody Order order) { }
在5月的情况下，我想使用springboot
浏览 7提问于2022-11-07得票数 0
Kafka版本为1.0，kafka客户端为2.11-1.0
spring.cloud.stream.bindings.orderEvent.destination=localhost spring.cloud.stream.bindings.kafka.binder.zkNodes=localhost
浏览 2提问于2018-04-13得票数 0
回答已采纳
我的要求是通过SSL将Kafka主题与Spring和Apache连接起来，为此，我编写了以下代码，但我面临一个错误，如sun.security.validator.ValidatorException:(){ store.setResource("kafka.client.truststore.jksthis path to point to your truststore/keysto
浏览 3提问于2020-10-21得票数 0
我目前正在做一个小项目，我需要将kafka集群连接到mongodb，以便将发布到kafka主题的消息存储在mongodb数据库中。我目前有一个本地kafka集群，一个springboot生产者发布消息到一个主题，一个springboot消费者在本地消费这些消息。compass…我一直在看教程，我想我必须使用某种类型的接收器连接器( mongodb连接器)来做我想做的事情，但大多数示例都是基于mongodb atlas和confluent或亚马逊网络服务托管的kafka...is，有任何好
浏览 1提问于2021-05-09得票数 0
尝试将使用springboot的springboot应用程序从2.8.4升级到2.9.3版本。implementation("org.springframework.kafka:spring-kafka:2.9.3") {
exclude group: "org.apache.kafka", module: "kafka-s
浏览 22提问于2022-11-30得票数 0
回答已采纳
我在我的项目中使用了Kafka和Springboot，现在我有了外部Kafka集群和SpringBoot微服务项目。使用yml文件，我成功地创建了Kafka生产者和消费者，然后应用程序和kafka就可以很好地通信了。希望在我的Eco系统中不设置任何外部Kafka组件的情况下进行功能测试。
我真的不知道该怎么做，有没有人能帮我一下。
浏览 5提问于2019-01-18得票数 1
我按照这个例子构建了一个简单的Kafka生成器来进行一些测试。但是，我的Kafka实例不在本地，由我公司的基础架构团队管理，因此它在远程服务器上运行。我需要使用application.properties文件来定义kafka地址池还是类似这样的东西？spring.kafka.bootstrap-servers=[kafka-server-1:port],[kafka-server-2:port]
spring.kafka.consumer.group-id一开始，它似乎
浏览 54提问于2021-11-09得票数 1
我在一个springboot应用程序中有一个简单的kafka消费者侦听器，如下所示：public void receive(String注意:我也希望kafka的配置是定制的(而不是默认的springboot结构)
浏览 11提问于2019-07-11得票数 1
回答已采纳
1回答
我在camel-kafka-starter依赖中使用了一个Kafka组件。在这个中，我被推荐使用“定制器”。我如何在我的spring boot应用程序中使用它？
浏览 47提问于2020-02-25得票数 0
回答已采纳
将数据从mysql传递到kafka produce的最佳方式是什么 我知道有很好的kafka连接器。然而，我想使用springboot框架。因为我需要转换数据并与其他http结果合并，然后我想产生数据到kafka。 那么有没有什么好的例子，github，博客wahtever~？
浏览 44提问于2020-07-21得票数 1
在我的Kafka侦听器中，我抛出一个运行时异常，如下所示：}@KafkaListener(topics= "Kafka-springboot
浏览 1提问于2020-04-05得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
