回答情况：
提问时间：
问题标签：
如何处理camel交换机向Kafka end point.Kafka推送消息时的拒绝连接异常，可能会宕机，或者在推送过程中会宕机。
浏览 1提问于2018-10-03得票数 1
getProductSource(ProductBuilder dataAccess) {
}; 如果kafka当我测试时，即使kafka宕机了，数据也会不断地从数据库中读取，并且不断地试图将记录发送到kafka？ 预期的性能是在kafka宕机后停止数据轮询。 有没有可能实现这一点的方法？
浏览 31提问于2020-12-21得票数 0
当Kafka broker变得不可用时，我的spring boot 2.1.5消费者应用程序宕机，异常如下。它使用的是spring-kafka 2.2.6。我需要我的应用程序保持运行，并在kafka broker回来后继续消费。org.springframework.context.ApplicationContextException: Failed to start bean
'org.springframework.kafka.config.internalKafkaListenerEnd
浏览 32修改于2019-12-12得票数 1
回答已采纳
例如，我有3个Kafka代理和一个包含3个副本的分区。我们假设3个副本均匀分布在每个代理上。那么，如果一个副本(关注者)宕机，Kafka会怎么做呢？Kafka会创建一个新的副本，还是只是等待失败的副本回来？
而此时，如果producer继续向broker写入数据，会不会造成数据丢失？
浏览 0提问于2018-04-10得票数 0
我在服务器启动时启动Kafka consumer。如果Kafka集群长时间(几个小时)宕机，对消费者会有什么影响？Kafka再次上线后会收到消息吗？
浏览 46提问于2019-12-12得票数 0
我有一个web应用程序，通过读取请求中的一些值发送kafka消息。如果我的kafka服务器宕机了，我该如何发送错误状态。现在，在服务器宕机的情况下，prodcuer不断地尝试连接，并无限地记录以下错误。错误：
14:56:10.181 [kafka-producer-network-thread | producer-1] WARN o.a.kafka.common.network.Selector:producer-context id="kafkaProducerCont
浏览 0提问于2016-03-13得票数 0
我正在使用Kafka producer发布消息到其他一些kafka主题，它工作得很好。示例模板如下： kafka-template="template"channel="inputToKafka"上述语句是否支持kafka消息驱动入站通道适配器中支持的erro
浏览 1提问于2017-08-07得票数 0
回答已采纳
我在一个kafka集群中创建了两个kafka brokers。当一个经纪人宕机时，我无法将任何数据提供给kafka消费者。我使用这个命令来读取来自消费者的消息： --bootstrap-server
浏览 10修改于2021-01-22得票数 0
我正在使用Debezium SQL Server Source connector通过CDC将数据推送到Kafka。SQL Server表中的数据是连续插入的。当Kafka宕机时，数据还会插入到该表中吗？如果是这样，当我的Kafka打开时，如何获得这些记录？
浏览 13修改于2020-05-22得票数 0
回答已采纳
我正在我的应用程序中测试Kafka broker down场景。如果Kafka broker宕机，我的应用程序中会出现NonResponsiveConsumerEvent事件，如果我带回我的Kafka broker，是否有任何事件或任何东西可以用来通知用户它已成功重新连接
浏览 47提问于2019-10-16得票数 0
回答已采纳
我在Kafka中设置了一个主题的时间间隔为7天，我正在从Kafka获取数据并将其存储在数据库中，但从过去5天我的数据库服务器宕机了，现在我必须从Kafka获取最近5天的消息并将其存储在数据库中。注:从过去5天开始，Kafka没有问题。
浏览 0提问于2017-09-05得票数 1
3回答
我在我的本地主机上设置了Kafka，并试图监控Kafka生产者的行为，以防出现网络问题。
即使当所有代理都关闭时，生产者也不会给出任何错误。我使用的是同步制作器和Kafka 0.8版。如果所有的代理都宕机了，生产者有没有办法收到异常？
浏览 0提问于2015-10-16得票数 0
= new ZkHosts("server-1:2181");
"/" + TopologyConstants.KAFKA_QUEUE.SOURCE, ID);
问题是，如果我有一个zookeeper quo
浏览 16提问于2018-02-20得票数 0
回答已采纳
我正在尝试使用mirror maker将数据从一个kafka集群复制到另一个kafka集群。假设主集群宕机，是否可以自动向第二个集群发送kafka消息？
浏览 1提问于2017-04-11得票数 2
我有一个非常简单的Quarkus微服务，它使用smallrye reactive messaging (kafka)。有时我的kafka经纪人宕机了，我得到了以下日志： 2020-09-24 04:04:27,067 WARN [org.apa.kaf.cli.NetworkClient] (kafka-producer-network-thread2202 (id: -1 rack: null) disconnected 2020-09-24 04:04:27,083 WARN [org.apa.kaf.cli.Netw
浏览 36提问于2020-09-27得票数 1
我知道Kafka Queue Partition中的所有消息(或偏移量)都有它的偏移量，它负责偏移量的顺序。但是，如果我有一个Kafka Consumer Group (或单个Kafka Consumer)，它正在读取特别是Kafka主题分区，那么它如何维护读取的偏移量消息，以及谁维护这个偏移量计数器？如果消费者宕机，那么新的消费者将如何开始读取下一个未读(或未确认)偏移量。
浏览 18修改于2020-07-04得票数 1
回答已采纳
我有一个运行在AWS上的kafka集群，由3台机器组成:从kafka1到kafka3我希望确保在代理失败的情况下，客户端仍然能够获取元数据。:9092 check inter 3s fastinter 1s
server kafka2 <em
浏览 7提问于2017-07-20得票数 4
我有一个非常奇怪的问题，我在Scala中实现了一个Kafka生产者客户端，当Kafka集群启动时，一切都正常工作。也就是说，生产者将数据正确推送到Kafka中。然而，如果我设置我的生产者是‘异步’，Kafka生产者客户端将正确地放置数据，如果集群启动和工作，但生产者也推送数据into...the无效...如果集群关闭了！也就是说，如果集群宕机，Kafka生产者不会返回错误。
这对我来说是一个担忧，因为当生产者找到要推送到Kafka中的数据时，它会删除data...so的
浏览 2提问于2014-10-29得票数 0
场景是: kafka-source，flume memory-channel，hdfs-sink。如果flume服务宕机，是否可以存储topic分区的偏移量，并在恢复后从正确的位置消费？
浏览 3修改于2016-06-12得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号