spring-kafka 相关问题

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

Spring Kafka @SendTo不发送标题

我正在使用ReplyingKafkaTemplate向Kafka发送消息，并使用kafka_correlationId发送消息。但是，当它到达我的@KafkaListener方法并将其转发到回复主题时，...

spring apache-kafka spring-kafka spring-kafka-test

回答 1 投票 0

Spring kafka不会重试没有提交抵消

我怎么能停止春天kafka不重试不是来自主题的readed消息。例如，我杀了应用程序，然后重新启动它，我的消费者开始消耗不消耗的消息。我怎么能够 ...

apache-kafka spring-kafka

回答 1 投票 0

Spring-Kafka并发属性

我正在使用Spring-Kafka编写我的第一个Kafka Consumer。看看框架提供的不同选项，并对它们有一些疑问。有人可以在下面说明......

spring apache-kafka spring-kafka

回答 2 投票 2

如何在@KafkaListener中使用Container Stopping ErrorHandler在Kafka服务器DisconnectException的情况下终止应用程序

我想处理Server DisconnectException并在服务器DisconnectException发生时终止应用程序如何捕获此错误并停止应用程序？ @KafkaListener（topics = {“$ ...

spring-kafka

回答 1 投票 0

Spring KafkaListener：如何知道它什么时候准备好了

我有一个简单的Spring Boot应用程序，它从Kafka读取并写入Kafka。我使用EmbeddedKafka编写了一个SpringBootTest来测试所有这些。主要问题是：有时候测试失败了......

spring spring-boot apache-kafka spring-kafka spring-kafka-test

回答 2 投票 1

2位kafka消费者使用不同的SSL配置从2个不同的主题中读取

我正在编写一个Spring启动应用程序，它将使用2个不同的主题并处理该消息。这两个主题托管在不同的群集上，并具有不同的SSL配置。我想要 ...

java apache-kafka spring-cloud-stream spring-kafka

回答 2 投票 0

将apache kafka polling迁移到spring kafka

在spring-boot（版本2.1.4）应用程序中，需要将apache-kafka迁移到spring-kafka。目前的kafka消费者做：1）KafkaConsumer bean在申请时初始化...

spring-kafka

回答 1 投票 0

发送到kafka主题时序列化消息出错

我需要测试一个包含标题的消息，所以我需要使用MessageBuilder，但我无法序列化。我尝试在生产者道具上添加序列化设置，但它不起作用。能够 ...

apache-kafka kafka-producer-api spring-cloud-stream spring-kafka

回答 3 投票 2

确定Kafka-Client与kafka-broker的兼容性

在远程kafka云集群中，kafka代理将更新为新版本（5.1），因此适用新的kafka协议。现在我应该更新我的kafka客户端以便...

java apache-kafka spring-kafka

回答 1 投票 0

@EnableBinding（Source.class）throws无法将'server.error.include-stacktrace'下的属性绑定到org.springframework.boot.autoconfigure.web

春云流和卡夫卡。添加以下依赖项后，将显示此错误。（如果我注释掉@EnableBinding（Source.class），一切正常。）

spring-boot spring-cloud spring-cloud-stream spring-kafka

回答 1 投票 0

是否可以重新使用GlobalKTable？

我想ReKey一个GlobalKTable（可能在初始化它时，因为我相信它们只在创建时才被读取）。这可能吗？我在Spring / Java Kafka中有两个主题...

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

回答 1 投票 4

扩展消费者@StreamListener

我们使用spring cloud来提供异步任务。我想知道是否有任何方法可以扩展@StreamListener设置的监听器？目标是在一个应用程序实例中拥有多个工作程序。 ...

spring-boot spring-cloud spring-cloud-stream spring-kafka

回答 1 投票 0

更改Embedded Kafka中的zookeeper日志目录

我正在使用spring Kafka在我的应用程序中为JUnit测试设置Embedded-Kafka。为zookeeper日志目录设置的位置/属性是什么。使用Embedded-Kafka时，我没有......

spring-kafka

回答 1 投票 0

在Kafka JSON序列化中将超类型作为类型信息发送

我正在使用Spring Boot使用Kafka将数据从一个应用程序发送到另一个应用程序。我的设计使用一个接口来声明正在发送的数据：package domain; interface Data {public String ...

java spring spring-boot apache-kafka spring-kafka

回答 1 投票 0

Kafka Consumer不断获取2天前每5分钟生成和消费的数据

我正在研究卡夫卡消费者，我注意到它正在消耗本应该在2天前消费的消息。它大约每5分钟重复这些消息，制作人不再......

apache-kafka kafka-consumer-api kafka-producer-api spring-kafka

回答 2 投票 1

应该是抽象侦听器ContainerFactory真正关闭它用于检查主题的消费者

在org.springframework.kafka.listener.AbstractMessageListenerContainer中，当启动容器时，checkTopics方法使用Kafka使用者检查代理是否存在订阅主题...

spring-kafka

回答 1 投票 0

使用Spring Boot自定义kafka主题分区

有没有办法根据使用Spring Boot在有效负载属性上计算的哈希来创建分区键。在apache-kafka中有一个名为Partition的接口，但不知道如何分配...

spring spring-boot spring-kafka

回答 1 投票 0

将kafka日志消息重定向到单独的日志（catalina.out除外）

我有一个使用Spring Boot设置的项目，我使用Spring Kafka来使用消息。该应用程序部署在独立的Tomcat实例上。 Spring Kafka正在产生大量的伐木......

java apache-kafka logback spring-kafka

回答 1 投票 0

春天kafka有多个生产者的代码示例吗？

我有一个可能需要多个生产者的应用程序。我看到的所有代码示例似乎都支持单个生产者，在app启动期间从app读取配置。如果有多个生产者，我们......

spring apache-kafka spring-kafka

回答 2 投票 1

Spring Kafka Error Handler如何避免无限循环

我希望有人可以给我一个提示，希望我在这里做错了。我为批量监听器编写了一个自定义错误处理程序，它应该在收到的记录后面查找，然后将它们发送到dlq。我很累但是......

java spring apache-kafka spring-kafka

回答 1 投票 0

spring-kafka 相关问题

最新问题