spring-kafka 相关问题

Spring for Apache Kafka（spring-kafka）项目将核心Spring概念应用于基于Kafka的消息传递解决方案的开发。

Spring Boot 中的多个 Kafka 生产者

我有一个用例，要求我有多个 Kafka Producer（基于配置）。即，如果我的配置有 3 个想要接收数据的租户，我想启动 3 个生产者（全部

java spring spring-boot spring-kafka

回答 1 投票 0

SpringBoot KafkaConsumer从一开始就没有消费

我有一个 spring boot kafka 消费者，它为特定消费者组 ID 配置了 auto.offset.reset=earliest 。我希望消费者从一开始就在应用程序休息时使用消费者......

java spring-boot spring-kafka

回答 1 投票 0

根据条件暂停和恢复 ReactiveKafkaReceiver

我正在尝试为 kafka 消费者实现一个带有 resilence4j 的断路器，该消费者又调用下游 API。 kafka 消费者和 API 都是响应式的。要求：要有一个Ci...

spring-kafka resilience4j reactive-kafka

回答 1 投票 0

kafka 中的分区不均匀/无密钥

我有一个主题，有 3 个分区，只有 1 个使用者，我使用的是默认分区器，在本例中为“粘性”。其他一切都默认。从生产者发送的数据...

java apache-kafka apache-kafka-streams spring-kafka

回答 2 投票 0

在反应流中调用 Kotlin 挂起函数

我使用 Spring Boot 应用程序和 Kotlin lang。我想通过反应式 Kafka 消费者接收消息，然后将这些消息传递给暂停的 Kotlin 函数并在那里使用协程，然后...

kotlin apache-kafka spring-webflux kotlin-coroutines spring-kafka

回答 1 投票 0

如何在应用程序中获取Kafka的broker地址？

我在项目中使用Java、Spring-Boot和Kafka。 @Autowired 私人 KafkaTemplate kt; 私有无效产生（） { MyRecord mr = new MyRecord("abc");

java spring-boot apache-kafka spring-kafka

回答 1 投票 0

从Kafka获取回复消息

我正在使用 Kafkajs 向 Spring Boot 应用程序生成消息，该应用程序实现为回复模板 @KafkaListener（主题= KHQRTopic.GENERATE_KHQR，groupId = KafkaConfiguration.CONSUMER_GROUP） @

node.js spring-cloud spring-kafka

回答 1 投票 0

spring-kafka监听器重试如何在max.poll.records大于1的情况下工作？

我已阅读此答案，我很清楚记录会在下一次民意调查之前一次交给听众。有人可以告诉我在处理任何记录的过程中，如果 lis...

spring-boot spring-kafka

回答 1 投票 0

实现Spring Kafka重试

我有一个主题，其中包含两种类型的消息：一种是创建数据，一种是更新。我遇到的情况是某些更新事件在创建事件之前到达。我试图暗示...

spring-boot spring-kafka spring-retry

回答 1 投票 0

使用Springboot构建kafka生产者失败

我正在使用 Springboot 做一个简单的 kafka 示例项目，我遇到了生产者未创建但其余部分运行良好的错误。我遇到的错误似乎引发了异常

java spring-boot apache-kafka spring-kafka

回答 5 投票 0

SpringBoot 嵌入式 Kafka 使用 Avro Schema 生成事件

我创建了以下测试类来使用 AvroSerializer 生成事件。 @SpringBootTest @EmbeddedKafka（分区= 1，brokerProperties = {“listeners = PLAINTEXT：// localhost：9092”，＆...

java apache-kafka spring-kafka confluent-schema-registry spring-kafka-test

回答 2 投票 0

如何使用 Mockito 对 Kafka 的 RecordIntercept 接口的拦截方法进行单元测试

我有 KafkaRecordInterceptor 类，它实现了 RecordInterceptor 接口如下 @成分公共类 KafkaRecordInterceptor 实现 RecordInterceptor...

apache-kafka mockito spring-kafka junit5 spring-kafka-test

回答 1 投票 0

Kafka 生产者将消息发布到辅助集群

建议的集群设置的描述 2个数据中心，每个数据中心有5个节点的Kafka集群集群具有相同的主题和相同的生产者/消费者实例没有数据

apache-kafka spring-kafka kafka-producer-api failover

回答 2 投票 0

动态创建消费者spring kafka

我正在创建一个与另一个服务通信的服务，以便识别要收听的 kafka 主题。 kafka主题可能有不同的键和值类型。因此，我想动态地创建...

apache-kafka kafka-consumer-api spring-kafka

回答 1 投票 0

在spring kafka中面对org.apache.kafka.common.errors.InvalidPidMappingException

我正在使用 Spring Boot 2.1.9 和 Spring Kafka 2.2.9。我的 Spring Boot 应用程序在过去两周内一直处于闲置状态，它正在运行，但仍然没有人访问 API。但是当我今天开始使用时，f...

spring-boot apache-kafka spring-kafka

回答 3 投票 0

在springboot应用程序中间歇性消费kafka消息

我有以下用例：我的应用程序无法处理的消息（可能是由于与网络等相关的一些间歇性问题）正在写入 kafka 主题。我想要

java spring-boot apache-kafka spring-kafka spring-scheduled

回答 2 投票 0

带有Spring云流Binder和Json反序列化器的模式注册表

我是 Kafka 的新手，我正在尝试使用模式注册表并与 spring 云流绑定消费者集成，我已经研究了很多并获得了很多参考资料，但没有真正解决问题。所以可以...

schema spring-kafka apache-kafka-streams confluent-schema-registry

回答 1 投票 0

Spring Kafka集成测试类如果不先执行就会失败

我编写了以下集成测试类： @ActiveProfiles(“测试”) @SpringBootTest @测试容器类 DomainCourseMapperServiceApplicationIntegrationTest { @容器静电...

java spring spring-boot spring-kafka testcontainers

回答 1 投票 0

生产环境中，尤其是新部署应用程序时，如何处理大量积压的Kafka消息？

我在生产环境（在 AWS 上）上新部署了一个 Spring Boot 应用程序，该应用程序使用各种主题的 Kafka 消息，这些主题在

spring-boot apache-kafka amazon-ecs spring-kafka

回答 2 投票 0

Spring Kafka 优雅关闭

我正在使用 spring 框架和 spring Kafka 为一些 kafka 主题编写消费者。由于某种原因，我必须使用 spring-kafka 1.3。我已经完成手动配置来读取所有主题，创建

java spring apache-kafka spring-kafka

回答 1 投票 0

spring-kafka 相关问题

最新问题