回答情况：
提问时间：
问题标签：
当我向kafka发送消息时，它关闭了，我想单独处理它。但是当我向kafka发送消息时，它是关闭的，没有异常，所以我无法确定kafka是否关闭。有什么方法可以捕获异常和丢失的消息。linger.ms", 1); props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer
浏览 20提问于2019-02-01得票数 6
回答已采纳
getProductSource(ProductBuilder dataAccess) {
}; 如果kafka当我测试时，即使kafka宕机了，数据也会不断地从数据库中读取，并且不断地试图将记录发送到kafka？ 预期的性能是在kafka宕机后停止数据轮询。 有没有可能实现这一点的方法？
浏览 31提问于2020-12-21得票数 0
包含所有“运行状况”指标的HealthEndpoint.invoke (db、磁盘空间...)如果Kafka关闭，则不会响应。因此，在这种情况下，我无法获得任何健康指标。
浏览 21提问于2019-02-01得票数 1
所以有一个Kafka集群，我们在它上面有一个Schema注册表来验证主题的模式。由于某些维护原因，如果模式注册表关闭，Kafka将在该持续时间内停机，并且不会接受任何新的传入数据请求？
浏览 0修改于2018-09-02得票数 1
我在服务器启动时启动Kafka consumer。如果Kafka集群长时间(几个小时)宕机，对消费者会有什么影响？Kafka再次上线后会收到消息吗？
浏览 46提问于2019-12-12得票数 0
我有3个节点的kafka集群，每个节点都有zookeeper和kafka。如果我显式地杀死引导节点zookeeper和kafka，那么整个集群都不会接受任何传入的数据，并等待节点返回。另外，两个kafka节点未响应以下错误。如果您想要可用节点上的kafka日志？(kafka.zookeeper.ZooKeeperClient)
[2020-10-08 19:40:13,709] INFO [ZooKeeperClient Kafka server] Waiting(<e
浏览 32修改于2020-10-08得票数 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
无法发送；嵌套异常是org.apache.kafka.common.errors.TimeoutException:使1条记录过期- 30030 :自批量创建以来已过0.5毫秒，外加延迟时间
如何处理这个问题
浏览 0修改于2018-04-11得票数 0
我只需要npm安装kafka-node并使用kafka_0.9.2-0.8.2.1。我有一个nodejs和两个代理，kafka1，kafka2。动物园管理员在kafka1。nodejs客户端代码如下：(node_js_machine格式)当我杀死nodejs当前连接的kafka进程时。nodejs崩溃并退出。var csUtil = require('cs-js-common');
var kafka = require('<
浏览 0提问于2015-05-27得票数 0
你好，我正在写一个使用spring cloud stream的kafka消费者-生产者。现在，如果我第三次重启应用程序，在中间时间间隔(两次失败)收到的消息丢失，kafka使用者将获取最新的消息，并跳过我退出代码的消息。applicationContext,()-> 0); } 应用程序属性文件 #Spring Cloud Streams Configurationspring.cloud.stream.kafka.binder.brokersspring.cloud.stream.bindings.in
浏览 33修改于2019-02-19得票数 1
由于重新部署，我们的Kafka集群会定期关闭并重新创建。
每当集群再次返回时，我们观察到尽管之前的主题被选取(可能来自zookeeper)，但之前的消费者组并没有被创建。
浏览 4提问于2018-08-06得票数 1
我使用的是Kafka 0.11.0.0。我有一个发布到Kafka主题的测试程序；如果zookeeper和Kafka服务器关闭(这在我的开发环境中是正常的；我会根据需要启动它们)，那么对KafkaProducer<>.send()的调用就会无限期地挂起基本上，我希望我的测试工具能够告诉我，“嘿，笨蛋，启动Kafka!”而不是绞死。kafkaProducer.send(new ProducerRecord<>(K
浏览 3提问于2017-11-18得票数 7
如何处理camel交换机向Kafka end point.Kafka推送消息时的拒绝连接异常，可能会宕机，或者在推送过程中会宕机。
浏览 1提问于2018-10-03得票数 1
当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 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
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号