spring-kafka 相关问题

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

Spring Kafka Retry会在不同分区中选择消息吗？

我想知道Spring Kafka如何在分配给实例的多个分区的情况下处理重试。 Spring Kafka是否会根据重试策略和退避重试相同的消息...

spring-kafka spring-retry

回答 1 投票 0

kafka集群与spring之间的事务传输消息

我有两个卡夫卡集群。我需要使用kafka-spring在它们之间实现一种同步。 [集群A，主题A] [集群B，主题B]我创建了监听器......

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

回答 1 投票 0

Spring Kafka / Spring Cloud Stream如何保证涉及数据库和Kafka的事务性/原子性？

Spring Kafka，以及Spring Cloud Stream，允许我们创建事务性生产者和处理器。我们可以看到其中一个示例项目中的功能：https：//github.com/spring -...

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

回答 1 投票 0

没有调用Spring kafka @KafkaListener

我正在尝试使用spring-kafka将kafka与我的Spring启动（v2.0.6.RELEASE）应用程序集成。现在我想拥有一个消费者和一个制作人。我让制作人工作得很好，我可以看到......

java spring apache-kafka spring-kafka

回答 1 投票 0

spring-kafka中未应用的最小取出字节数属性

这是我的消费者配置：@Configuration @EnableKafka public class KafkaConfiguration {@Value（“$ {kafka.bootstrap-servers}”）private String bootstrapServers; @Bean公共地图

java spring spring-boot apache-kafka spring-kafka

回答 1 投票 1

使用Kafka实现STOMP协议

我正在使用websocket协议开发一个用于web平台的聊天模块，并将STOMP用作消息协议。这是我第一次使用任何消息代理，Kafka是公司使用的那个......

java websocket apache-kafka stomp spring-kafka

回答 1 投票 0

如何调查Kafka-stream处于ERROR状态的原因

我正在使用Spring Cloud Finchley.RELEASE与RocksDb和Kafka-Streams进行生产应用。有时Kafka-Streams进入ERROR状态，除了...之外无法访问商店

apache-kafka apache-kafka-streams spring-cloud-stream spring-kafka

回答 1 投票 0

Spring Kafka：ApplicationContext中不同对象的多个侦听器

我可以请与社区核实听取多个主题的最佳方式是什么，每个主题包含不同类的消息？我一直在玩Spring Kafka ...

java apache-kafka spring-kafka

回答 3 投票 6

断开连接后Kafka消费者重新连接

我使用Spring Boot和Spring Kafka设置了我的项目，并且有三个消费者。检查日志，我可以看到消费者不时断开连接：catalina.out：2019-04 -...

apache-kafka kafka-consumer-api spring-kafka

回答 1 投票 3

kafka的汇编和Spring模式注册表

我正在为kafka设置架构注册服务器。我已经使用了融合模式注册表，一切都很好，但后来我看到，你可以用更少的麻烦设置一个默认的，弹簧。所以我做了但是我...

apache-kafka avro spring-cloud-stream spring-kafka confluent-schema-registry

回答 1 投票 0

如何处理spring-kafka中的错误和重试

这是一个与以下问题相关的问题：https：//github.com/spring-projects/spring-kafka/issues/575我在read-process-write循环中使用spring-kafka 1.3.7和事务。为此，我应该使用......

spring-kafka

回答 1 投票 0

自动装配时没有打印值的KStream对象

我正在尝试创建kstreams bean并在我的服务中自动装配它。但即使我得到相同的对象stream.print（）没有给出任何值，但在同一个bean内打印正在工作。我觉得我是 ...

apache-kafka apache-kafka-streams spring-kafka

回答 1 投票 0

将BlockingQueue传递给Spring KafkaListener

我是Java，Spring和Kafka的新手。情况就是这样：我使用了@KafkaListener注释来创建一个看起来像这样的Kafka Consumer：public class Listener {private ...

java spring apache-kafka listener spring-kafka

回答 1 投票 0

使用KafkaTransactionManager在事务KafkaTemplate中基于事件的提交

Spring管理的KafkaTemplate提供了template.send（record）.addCallback（... template.executeInTransaction（...现在让我说我有一个方法doWork（），它在一个事件上触发（比如一个TCP / IP ...

java spring kafka-producer-api spring-kafka

回答 1 投票 0

Kafka：同一个使用者组中的多个实例在主题内部监听相同的分区

我有两个kafka使用者实例，配置了相同的使用者组并在同一主题中侦听分区0。问题是当我向主题发送消息时。消息是......

spring-boot apache-kafka kafka-consumer-api spring-kafka

回答 1 投票 1

嵌入式Kafka迁移状态存储在具有不同@StreamListener的两个实例之间

我有一个SpringBoot应用程序，它有两个通过Spring Cloud映射的流处理器。每个处理器都有自己的@StreamListener用于不同的主题。一个处理器将聚合数据写入可查询...

apache-kafka spring-cloud apache-kafka-streams spring-kafka embedded-kafka

回答 1 投票 0

Spring Kafka获得分配的分区

我知道我可以从哪个分区记录中找到，但我想知道有什么方法可以动态地获取在特定时刻为消费者分配的分区吗？也许我需要实施一些......

apache-kafka kafka-consumer-api spring-kafka

回答 2 投票 3

也许不公开或无效？使用Spring的Websocket和Kafka

当我尝试使用主题中的数据（主题名称基于用户）时，在运行时我尝试使用主题中的消息，但是我收到以下错误。引起：组织....

spring spring-websocket spring-kafka

回答 1 投票 0

Kafka消费者民意调查，偏移0不返回消息

我使用spring-kafka来轮询消息，当我为消费者使用注释并将offset设置为0时，它将最早看到所有消息。但是当我尝试使用注入的ConsumerFactory来...

apache-kafka spring-kafka

回答 1 投票 0

如何使用Spring-Kafka使用Confluent Schema注册表读取AVRO消息？

如何使用Spring-Kafka使用Confluent Schema注册表读取AVRO消息？有样品吗？我在官方参考文件中找不到它。

avro spring-kafka confluent confluent-schema-registry

回答 2 投票 3

spring-kafka 相关问题

最新问题