2回答
我已经编写了一个简单的kafka配置和消费者类，如下所示：@Service * This consumerStringDeserializer.class); }现在需要注意的是，我需要在dev环境中禁用它我尝试禁用KafkaConfigura
浏览 42提问于2019-08-12得票数 1
目前我正在使用Spring boot 2.4.0和spring-kafka。 我想使用消费者和生产者，而不是kafka admin。它仍然“尝试”连接以生成KafkaAdmin并记录错误。这不是致命的，但有没有办法完全禁用kafka管理？
浏览 50提问于2021-01-05得票数 0
回答已采纳
具有消耗的KafkaStreams拓扑，并在一些处理步骤之后生成另一个kafka主题的结果，并配置为： num.stream.threads: 10 JConsole说有20个消费者线程，20个生产者线程在大量num.stream.threads的情况下，这似乎是一个很大的开销-在生产中，我们已经配置了64个，并且有400多个Java本机线程。
浏览 20提问于2019-03-22得票数 1
回答已采纳
我已经创建了一个带有三个分区的Kafka主题。在Spring-Kafka中使用ProducerFactory，我可以创建一个生产者实例。但是，我想创建三个生产者实例，因为我有三个分区。
浏览 2提问于2019-10-25得票数 1
我对Kafka和阅读文档有点陌生。卡夫卡办公网站有一个。其中应用程序被绑定到一个主题，并且消息一到达就被处理。结果会回发到主题或数据库。
浏览 5提问于2018-01-18得票数 1
我们有一个Kafka集群，想法是有一个Spring应用程序作为生产者，消费者和卡夫卡之间的桥梁。如何在Spring和Kafka之间创建一个持久的连接来发送和接收消息？
协议重要吗？
浏览 4提问于2021-11-26得票数 0
回答已采纳
我使用的是Axon版本(3.3)，它在SpringBoot主类中使用在我们的用例中它会将事件存储在事件存储中，然后将其移动到另一个kafka主题，供查询端微服务消费。
由于KafkaAutoCOnfiguration被禁用，我不能使用spring-kafka配置来编写消费者。我试着写了一个普通的Kafka spring Consumer，但由于
浏览 18提问于2019-07-12得票数 0
我有很多事务型消费者，他们都有一个基于JpaTransactionManager和KafkaTransactionManager的ChainedKafkaTransactionManager (都是@JPA one需要设置一个ThreadLocal变量，以便能够知道要连接到哪个DB (是租户id)。当启动应用程序时，在onPartitionsAssigned listener中，spring-kafka尝试创建一个链式txn，因此尝试创建一个JPA t
浏览 37提问于2020-01-29得票数 1
回答已采纳
1回答
我有一个弹簧引导服务，有一个卡夫卡的消费者。我使用spring-kafka来创建使用者。
从文档中可以看出，max.poll.records属性将有助于限制要获取的记录数量。如何使用spring-kafka实现这一目标？任何帮助都将不胜感激。
浏览 0提问于2018-10-17得票数 0
回答已采纳
在没有Spring Boot自动配置功能的情况下，是否可以仅将spring-kafka用作配置框架-类似于解析application.properties或application.yaml，并实例化消费者和生产者基本上，只为public static void main应用程序提供了最少的spring和spring-kafka。
谢谢
浏览 12提问于2020-03-04得票数 0
回答已采纳
据我所知，Apache Kafka文档中没有诸如批处理消费者之类的特殊概念，但spring-kafka可以选择使用以下代码片段创建批处理消费者。factory.setBatchListener(true); // <<<<<<<<<<<<<<<<<<<<<<<<<} 现在我的问题是， 我应该在什
浏览 17提问于2020-10-21得票数 0
回答已采纳
我正在编写一个Kafka消费者，为了学习的目的，这一次我考虑使用Spring-Kafka实现。到目前为止，我一直使用Java API来编写使用者。我想手动管理偏移量，所以我在Spring-Kafka包中搜索类似于ConsumerRebalanceListener的东西。我的成功之处在于，我在Spring中遇到了可以用来代替ConsumerRebalanceListener的ConsumerAwareRebalanceListener。但是当我查看ConsumerAwar
浏览 49提问于2019-04-10得票数 0
我正在编写一个使用'org.springframework.kafka.annotation.KafkaListener‘(@KafkaListener)注释的kafka消费者。该注释期望主题在订阅时已经存在，如果主题不存在，则尝试创建主题。 在我的例子中，我不希望使用者创建一个默认配置的主题，但它应该创建一个自定义配置的主题(比如分区的数量、清理策略等)。在spring-kafka中有这样的选择吗？
浏览 1提问于2019-08-24得票数 1
我们今天遇到了一个问题，一个Kakfa消费者无法连接到任何代理，日志中没有错误消息。当它通过SSL连接并且指向错误的信任库时，它未能连接。但是，虽然在这种情况下，这是由于SSL失败，但我也曾见过其他情况，即使用者无法连接，日志中没有错误消息。
是否有一种方法来配置卡夫卡使用者，以便在使用者无法连接到代理？时记录错误消息--我正在寻找一个通用解决方案，而不是特定于SSL连接问题的解决方案。(我们使用的是：org.apache.kafka
浏览 1提问于2018-11-07得票数 3
0回答
是否有人使用了spring-kafka 2.0.Release并创建了一个使用confluent模式注册表作为反序列化消息的源的消费者?如果是，你能给我举个例子吗？我正在尝试解决的问题是，我在我的kafka connect平台上有一个Debezium CDC连接器，可以在事件发生时流式传输来自MongoDB的事件。我必须截取这些事件，转换并重新传输。
浏览 5提问于2017-12-15得票数 1
我的目标是在每个分区的开头寻找消费者组中的所有消费者。我使用了spring-kafka，并尝试以如下方式使用ConsumerSeekAware接口：}
现在，它只对一个组中的一个消费者有效，但如果我想要开始一个以上的消费者怎么办？
浏览 0提问于2018-07-16得票数 1
回答已采纳
我在我的一个应用程序中使用Spring cloud Stream和spring-kafka，似乎每当有消费者重新平衡或GC时，由于弱引用，kafka消费者滞后量规被垃圾收集，因此返回NaN。我看到有人在这里提到了类似的问题和重现它的步骤。我们希望基于滞后量规自动缩放我们的应用程序。
浏览 2提问于2021-10-09得票数 0
2回答
我知道我可以找出来自哪个分区记录，但我想知道有什么方法可以动态地获得在特定时刻为消费者分配的分区？也许我需要实现一些侦听器来检测和跟踪分区分配信息？我将spring-kafka 1.3.2与ConcurrentKafkaListenerContainerFactory和@KafkaListener一起使用。
浏览 4提问于2018-02-20得票数 4
我正在使用spring-kafka 2.2.8.RELEASE和@KafkaListener注释来创建消费者，下面是我的消费者配置代码。ExponentialBackOffPolicy();
System.out.println("##### Got an er
浏览 29提问于2020-03-10得票数 0
回答已采纳
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
腾讯云开发者
