回答情况：
提问时间：
问题标签：
如何处理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
回答已采纳
我在服务器启动时启动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集群中创建了两个kafka brokers。当一个经纪人宕机时，我无法将任何数据提供给kafka消费者。我使用这个命令来读取来自消费者的消息： --bootstrap-server
浏览 10修改于2021-01-22得票数 0
我正在使用Kafka producer发布消息到其他一些kafka主题，它工作得很好。示例模板如下： kafka-template="template"channel="inputToKafka"上述语句是否支持kafka消息驱动入站通道适配器中支持的erro
浏览 1提问于2017-08-07得票数 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
我正在尝试使用mirror maker将数据从一个kafka集群复制到另一个kafka集群。假设主集群宕机，是否可以自动向第二个集群发送kafka消息？
浏览 1提问于2017-04-11得票数 2
例如，我有3个Kafka代理和一个包含3个副本的分区。我们假设3个副本均匀分布在每个代理上。那么，如果一个副本(关注者)宕机，Kafka会怎么做呢？Kafka会创建一个新的副本，还是只是等待失败的副本回来？
而此时，如果producer继续向broker写入数据，会不会造成数据丢失？
浏览 0提问于2018-04-10得票数 0
我知道Kafka Queue Partition中的所有消息(或偏移量)都有它的偏移量，它负责偏移量的顺序。但是，如果我有一个Kafka Consumer Group (或单个Kafka Consumer)，它正在读取特别是Kafka主题分区，那么它如何维护读取的偏移量消息，以及谁维护这个偏移量计数器？如果消费者宕机，那么新的消费者将如何开始读取下一个未读(或未确认)偏移量。
浏览 18修改于2020-07-04得票数 1
回答已采纳
最有用和人类可读的代码行似乎是：11-10 1111-10 11:36:55.854: I/DEBUG(19383): Crash log at 11-10 11:36:5511-10 11:36:55.854:
浏览 1提问于2012-02-12得票数 0
回答已采纳
Lcom/example/navigationdrawerexample/MainActivity;.getActionBar ()Landroid/app/ActionBar; 11Lcom/example/navigationd
浏览 1提问于2015-11-10得票数 1
回答已采纳
-10 21:44:00.414: INFO/System.out(2316): [ann, john, ann] 11-10 21:44:00.414: DEBUG/string is(2316): ann我试着做了答案中提到的所有事情，但我的logcat似乎并不起作用
浏览 0修改于2011-11-11得票数 37
回答已采纳
);}
当这一行代码想要执行时，将引发错误：日志猫：11-10 11:46:53.325: E/AndroidRuntime(19579): FATAL EXCEPTION
浏览 1修改于2017-05-23得票数 4
回答已采纳
(Android 4.1.2)11-10 14:37:12.503: D/MyApp(1570): debug. =================================11-10 14:37:12.503: D/MyApp(1570): debug.memory: allocated: 30.0
浏览 0提问于2013-11-10得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号