在ConsumerConfig中添加kafka autoStartUp false

文章/答案/技术大牛

发布

1回答

spring-boot、spring-kafka

如何在lvl属性中手动添加kafka属性autoStartUp false？我的意思是，例如，我可以这样做： @KafkaListener(autoStartUp = "false") 但我想在ConsumerProperties中，在自己的BeanPostProcessor中完成例如，我在ConsumerProperties中找不到此属性： Map props

浏览 216提问于2020-11-05得票数 0

回答已采纳

1回答

具有不同过滤策略的不同使用者

spring-kafka

在一个spring引导应用程序中，我们可以使用两个不同的过滤器策略来使用不同的使用者吗？如果是这样的话，我们如何将过滤策略连接到相应的使用者？(boot-2.3.8)注意:这两种属性是不同的。+ ":localhost:9092", ConsumerConfig.AUTO_OF

浏览 1提问于2021-05-04得票数 0

回答已采纳

1回答

@KafkaListener (Spring)的开始问题

spring、kotlin、spring-kafka

什么是需要要避免应用程序崩溃，请在此站点上启动另一个主题，建议在声明@KafkaListener.时设置autoStartup = "false"这真的有助于防止

浏览 1提问于2020-07-03得票数 3

回答已采纳

1回答

在消费者重新启动后，来自主题的Kafka消息正在被重放。

java、spring-boot、apache-kafka、kafka-consumer-api、kafka-producer-api

我正面临一个奇怪的问题，在卡夫卡，所有的卡夫卡消息，从主题正在重放消费者应用程序重新启动。有人能帮我吗我在这里做错了什么？(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, false); consumerconfigs.put(SESSION_TIMEOUT_MS_CONFIGTOPIC-1", groupId = "TOPIC-GRP", containerFactory = "kaListenerContainerFactory",co

浏览 4提问于2021-04-01得票数 1

1回答

启动Spring Boot应用程序而不检查Kafka服务器

spring、spring-boot、apache-kafka

我有一个应用程序，它使用2.10.0版本中的SpringBoot 2.10.0 version和kafka。org.springframework.context.ApplicationContextException: nested exception is org.apache.kafka.comm

浏览 216提问于2019-01-25得票数 2

1回答

KafkaConsumer没有处理在springboot中发布的所有请求

spring-boot、spring-mvc、apache-kafka、kafka-consumer-api、spring-kafka

一旦在使用者处收到消息，我就调用REST将记录保存到MongoDB中。但是所有上传给卡夫卡消费者的记录都没有保存到mongoDB。例:在向kafkaconsumer发送的5条记录中，只有3条保存到mongoDB。KafkaConsumerConfiguration@Configuration @Value("${spring.kafka.hostnameString GROU

浏览 1提问于2021-09-20得票数 0

回答已采纳

2回答

Kafka消费者组隐式命名算法

apache-kafka、kafka-consumer-api

当kafka客户端应用程序没有明确设置组id时，消费者组的名称到底是如何创建的，基于什么？我看到在某些情况下，当它包含服务器进程的名称时(比如当使用kafka-console-consumer.sh时，它类似于console- consumer -nnnn)启动了消费者，有时它反映了消费者通过监听器连接而不经过身份验证的事实

浏览 4提问于2019-03-13得票数 0

2回答

在Spring Boot中控制启用/禁用Kafka消费者

java、spring-boot、configuration、kafka-consumer-api

我已经在Spring Boot中配置了几个Kafka消费者。这是kafka.properties的样子(这里只列出了一个使用者的配置)：bootstrap.servers=enable.auto.commit=auto.commit.interval.ms=schema.registry.url=kafka.enabled=配置如下： @Configura

浏览 0提问于2019-01-30得票数 5

回答已采纳

1回答

如何配置kafka客户端的代理？

java、tcp、apache-kafka、proxy

我使用kafka-clients库来为Kafka主题创建一个消费者。Kafka broker (生产者)处于受限网络中，因此只有部分IP可以访问该服务。因此，我需要在Kafka客户端(消费者)上配置代理才能连接。在ConsumerConfig中，这可以在消费者构造函数中传递，没有代理条目。, IKafkaConstants.KAFKA_BROKERS); props.put(Cons

浏览 19提问于2020-02-28得票数 0

1回答

多主题kafka* Avro消息反序列化器*

java、spring-boot、apache-kafka、avro、confluent-schema-registry

我正在尝试用avro格式的kafka消息，我使用了以下代码：上面的代码对我来说工作得很好，但我必须监听来自多个主题的消息，并创建多个AvroGenerated文件，但我坚持配置，因为确认需要多个avro

浏览 8提问于2019-07-08得票数 2

回答已采纳

1回答

如何在KafkaListener之前添加筛选器以检查数据库连接是否稳定

spring-boot、apache-kafka、spring-kafka

试着在卡夫卡的听众面前理解是否有一个过滤器。该过滤器实际上应该检查数据库连接性，如果连接是稳定的，那么它应该继续使用kafka侦听器方法，否则不应该使用来自主题的任何消息。

浏览 9提问于2022-07-15得票数 0

1回答

无法将java.util.LinkedHashMap强制转换为类GenericEvent -对象映射器typeReference

spring-kafka、objectmapper、jackson-databind

消息是使用json反序列化器(Spring commons)从kafka主题中消费的。通用消息结构如下。); props.put(ConsumerConfig.ALLOW_AUTO_CREATE_TOPICS_CONFIG, false); props.put(ConsumerConfig.BOOT

浏览 13提问于2021-06-13得票数 0

1回答

春天卡夫卡的MessageListener在MessageListenerContainer停止后仍在消费

spring、apache-camel、spring-kafka

要做到这一点，当停止Camel组件时，我需要停止一个MessageListenerContainer，并最终停止在MessageListenerContainer中注册的MessageListener。我的问题是，当MessageListenerContainer停止时，MessageListener仍然在处理消息。LOG.info("Record processed: {}", data.offset()); };这是日志中的片段11-27T14:01:57.1

浏览 9提问于2020-11-27得票数 0

回答已采纳

1回答

Kafka不消费消息

apache-kafka、kafka-consumer-api、spring-kafka

我已经将我的kafka从版本0.10.2.0更新到versión 2.1.0，现在kafka不能消费消息。;configProperties.put(ConsumerConfig.GROUP_ID_CONFIG, topic + &

浏览 30提问于2019-06-23得票数 0

2回答

KafkaConsumer：“`seekToEnd()”不会使消费者从最新的偏移量中消费

kotlin、apache-kafka、kafka-consumer-api

然后，当使用者重新启动时，我希望它使用主题上的最新偏移量(即忽略在使用者关闭时发布到主题的记录)。我认为seekToEnd()方法可以确保这一点。然而，这种方法似乎根本没有效果。消费者开始从崩溃的偏移量中消费。 props[ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG] = config.kafka.stringDeserializerpr

浏览 2提问于2021-12-03得票数 6

回答已采纳

1回答

Kafka Java Consumer不会从上次停止的位置拾取消息

scala、apache-kafka、kafka-consumer-api

我在应用程序中使用org.apache.kafka.clients.consumer.KafkaConsumer来处理来自Kafka的消息。我注意到我的应用程序中有以下行为。如果我关闭我的应用程序，然后重新启动它，当我再次启动应用程序时，kafka生产者在此时间间隔内发送的任何消息都不会被应用程序中的kafka消费者接收到。下面是我如何在应用程序中配置kafka使用者 C

浏览 0提问于2018-08-28得票数 2

1回答

Spring引导Kafka类反序列化-而不是在受信任的包中

java、spring-boot、apache-kafka、json-deserialization

我知道这个问题很常见，但是在遵循不同的解决方案之后，我找不到一个有效的解决方案。在收到Kafka中的消息时，我想反序列化字符串和自定义的类对象。用字符串很好，但对我的班不行。我在使用者配置中添加了受信任的包(类所在的包是com.springmiddleware.entities )： public Map<String, Object> consumerConfigs: truste

浏览 1提问于2019-04-02得票数 8

回答已采纳

1回答

spark-streaming- kafka* -0-10_2.10中的部分kafka参数固定为none*

spark-streaming、spark-streaming-kafka

我使用spark- streaming -kafka-0-10_2.10版本2.0.2的spark -streaming-kafka。在KafkaUtils中，如下所示：logWarning(s“将执行器的${ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG}重写为false”) kafkaParams.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG，fals

浏览 0提问于2017-10-10得票数 4

1回答

消费者阅读__consumer_offsets传递不可读的信息

java、apache-kafka

还尝试添加stringDeserializer属性。有人对如何纠正这个问题有什么建议吗？同样，对此的引用是 ConsumerConnector consumer =kafka.consumer.Consumer.createJavaConsumerConnector(

浏览 1提问于2018-09-11得票数 1

回答已采纳

1回答

如何实现多节点单kafka消费端app的负载均衡？

spring-boot、apache-kafka、load-balancing、spring-cloud

我有一个spring boot Kafka监听器，它可以监听单个主题和消费者列表。现在这个spring boot应用程序现在有3个节点。现在，我需要确保列表消息的数量均匀地负载到所有3个节点。我如何在我的应用程序中实现这一点？

浏览 1提问于2021-04-28得票数 0

点击加载更多