腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
kafka
宕机
发送
消息
无
异常
java
、
apache-kafka
、
kafka-producer-api
当我向
kafka
发送
消息
时,它关闭了,我想单独处理它。但是当我向
kafka
发送
消息
时,它是关闭的,没有
异常
,所以我无法确定
kafka
是否关闭。有什么方法可以捕获
异常
和丢失的
消息
。linger.ms", 1); props.put("key.serializer", "
浏览 20
提问于2019-02-01
得票数 6
回答已采纳
1
回答
Apache camel
Kafka
异常
处理
apache-kafka
、
apache-camel
如何处理camel交换机向
Kafka
end point.
Kafka
推送
消息
时的拒绝连接
异常
,可能会
宕机
,或者在推送过程中会
宕机
。
浏览 1
提问于2018-10-03
得票数 1
1
回答
当
kafka
broker变得不可用时,如何防止正在运行的spring启动应用程序
宕机
?
spring-boot
、
spring-kafka
当
Kafka
broker变得不可用时,我的spring boot 2.1.5消费者应用程序
宕机
,
异常
如下。它使用的是spring-
kafka
2.2.6。我需要我的应用程序保持运行,并在
kafka
broker回来后继续消费。'; nested exception is org.apache.
kafka
.common.errors.TimeoutException: Timeout expired while fetchingtopic metadata 我已经尝试了@Kaf
浏览 32
提问于2019-12-12
得票数 1
回答已采纳
2
回答
避免重复
Kafka
生产者
消息
java
、
apache-kafka
、
spring-kafka
、
kafka-producer-api
我使用的是Spring boot.Java 8中的KafkaTemplate2)假设我处理了70行(我得到了成功确认),然后
Kafka
宕机
了(
Kafka
在重试机制计时内没有恢复) 那么,当我重新启动spring boot应用程序时,如何确保这70条
消息
不会再次
发送
。
浏览 0
提问于2020-04-28
得票数 1
1
回答
Kafka
-如何在第一个集群
宕机
时自动使用第二个集群?
apache-kafka
、
mirroring
我正在尝试使用mirror maker将数据从一个
kafka
集群复制到另一个
kafka
集群。假设主集群
宕机
,是否可以自动向第二个集群
发送
kafka
消息
?
浏览 1
提问于2017-04-11
得票数 2
1
回答
Kafka
spring集成如何处理
Kafka
服务器
宕机
spring-integration
、
apache-kafka
我有一个web应用程序,通过读取请求中的一些值
发送
kafka
消息
。如果我的
kafka
服务器
宕机
了,我该如何
发送
错误状态。现在,在服务器
宕机
的情况下,prodcuer不断地尝试连接,并无限地记录以下错误。错误: 14:56:10.181 [
kafka
-producer-network-thread | producer-1] WARN o.a.
kafka
.common.network.Selectorconstructor-arg v
浏览 0
提问于2016-03-13
得票数 0
3
回答
Kafka
集群长时间
宕机
后,消费者是否会恢复
apache-kafka
、
kafka-consumer-api
我在服务器启动时启动
Kafka
consumer。如果
Kafka
集群长时间(几个小时)
宕机
,对消费者会有什么影响?
Kafka
再次上线后会收到
消息
吗?
浏览 46
提问于2019-12-12
得票数 0
1
回答
如何在
kafka
宕机
时停止@InboundChannelAdapter的轮询,防止数据丢失?
spring-integration
、
spring-cloud
、
spring-kafka
、
spring-cloud-stream
、
spring-cloud-dataflow
getProductSource(ProductBuilder dataAccess) { }; 如果
kafka
当我测试时,即使
kafka
宕机
了,数据也会不断地从数据库中读取,并且不断地试图将记录
发送
到
kafka
? 预期的性能是在
kafka
宕机
后停止数据轮询。 有没有可能实现这一点的方法?
浏览 31
提问于2020-12-21
得票数 0
1
回答
Spring集成-
Kafka
生产者错误通道
spring-integration
、
spring-kafka
我正在使用
Kafka
producer发布
消息
到其他一些
kafka
主题,它工作得很好。示例模板如下:
kafka
-template="template"channel="inputToKafka"上述语句是否支持
kafka
消息</em
浏览 1
提问于2017-08-07
得票数 0
回答已采纳
1
回答
在未调用acknowledgment.acknowledge();之后恢复
Kafka
使用者
java
、
apache-kafka
、
kafka-consumer-api
我已经实现了一个简单的
Kafka
消费者,它实现了AcknowledgingMessageListener。在onMessage方法的和处有acknowledgment.acknowledge();,当一切顺利或只有一个可恢复的
异常
时,它就会被调用。在这种情况下,一切工作正常。因此,应用程序崩溃,但在重启后,它没有收到来自受影响的
Kafka
主题的任何
消息
。即使
Kafka
重启也无济于事,应用服务器重启也无济于事等等,但是其他的主题都工作得很好,
Kafka
并没有
宕机
。什么是正
浏览 2
提问于2017-11-02
得票数 0
2
回答
Kafka
Producer :处理异步
发送
回调
异常
apache-kafka
、
kafka-producer-api
我需要在异步
发送
到
Kafka
的情况下捕获
异常
。
Kafka
生产者Api自带函数send(ProducerRecord记录,回调回调)。但当我针对以下两个场景进行测试时:
Kafka
Broker
宕机
未预先创建的主题回调不会被调用。相反,我在代码中收到不成功
发送
的警告(如下所示)。 问题: 那么回调是否只针对特定的
异常
调用呢?在异步
发送
时,
Kafka
客户端何时尝试连接到
Kafka
broker :每次
浏览 228
提问于2019-05-17
得票数 3
3
回答
卡夫卡生产者行为
apache-kafka
、
kafka-producer-api
我在我的本地主机上设置了
Kafka
,并试图监控
Kafka
生产者的行为,以防出现网络问题。 即使当所有代理都关闭时,生产者也不会给出任何错误。我使用的是同步制作器和
Kafka
0.8版。如果所有的代理都
宕机
了,生产者有没有办法收到
异常
?
浏览 0
提问于2015-10-16
得票数 0
2
回答
无法在
kafka
集群设置中读取来自
kafka
消费者的
消息
apache-kafka
、
kafka-consumer-api
、
kafka-cluster
我在一个
kafka
集群中创建了两个
kafka
brokers。当一个经纪人
宕机
时,我无法将任何数据提供给
kafka
消费者。我使用这个命令来读取来自消费者的
消息
: --bootstrap-server
浏览 10
提问于2021-01-22
得票数 0
2
回答
如何使用Java从
Kafka
获取最近5天的
消息
java
、
apache-kafka
、
kafka-consumer-api
我在
Kafka
中设置了一个主题的时间间隔为7天,我正在从
Kafka
获取数据并将其存储在数据库中,但从过去5天我的数据库服务器
宕机
了,现在我必须从
Kafka
获取最近5天的
消息
并将其存储在数据库中。注:从过去5天开始,
Kafka
没有问题。
浏览 0
提问于2017-09-05
得票数 1
1
回答
Kafka
:谁负责维护消费者群体读取偏移量
消息
的上限?
apache-kafka
、
kafka-consumer-api
我知道
Kafka
Queue Partition中的所有
消息
(或偏移量)都有它的偏移量,它负责偏移量的顺序。但是,如果我有一个
Kafka
Consumer Group (或单个
Kafka
Consumer),它正在读取特别是
Kafka
主题分区,那么它如何维护读取的偏移量
消息
,以及谁维护这个偏移量计数器?如果消费者
宕机
,那么新的消费者将如何开始读取下一个未读(或未确认)偏移量。
浏览 18
提问于2020-07-04
得票数 1
回答已采纳
1
回答
GetKafka在Apache中未收到
消息
hortonworks-data-platform
、
apache-nifi
我正在尝试使用GetKafka处理器获取
消息
,但我无法获取。我使用
Kafka
命令行消费者测试了消费
消息
,它起作用了。我还能够成功地使用PutKafka processor将
消息
放入主题中。我在nifi-app.log中看到一个
异常
: 2016-08-03 09:34:33,722 WARN [70e1df87-6097-4ed0-9a40-7e36f9be6921_mydomain.com-1470231250839-1fbd0cfe-leader-finder-thread]
kafka</em
浏览 1
提问于2016-08-03
得票数 0
1
回答
检查
Kafka
中的所有滞后
apache-kafka
我想确保我在
Kafka
中不会丢失任何
消息
,即使我的消费者
宕机
了。我发现很多方法都不能很好的工作。
浏览 14
提问于2017-03-16
得票数 7
3
回答
如何以健壮的方式处理
kafka
发布失败
java
、
cassandra
、
redis
、
apache-kafka
、
kafka-consumer-api
我正在使用
Kafka
,我们有一个构建容错系统的用例,其中不会遗漏任何一条
消息
。所以问题来了:如果发布到
Kafka
由于任何原因而失败(ZooKeeper
宕机
,
Kafka
broker
宕机
等),我们如何才能可靠地处理这些
消息
,并在事情恢复后重播它们。同样,正如我所说的,我们不能承受哪怕一条
消息
失败。另一个用例是,我们还需要知道在任何给定的时间点,有多少
消息
由于任何原因而未能发布到
Kafka
,例如计数器功能,现在需要重新发
浏览 0
提问于2016-10-22
得票数 18
2
回答
从外部连接
kafka
时出现的问题
hadoop
、
cloudera
、
apache-kafka
、
hortonworks-data-platform
我正在使用hortonwork Sandbox for
kafka
服务器,试图用java代码连接eclipse中的
kafka
。使用此配置连接到生产者以
发送
消息
serializer.class=
kafka
.serializer.DefaultEncodersandbox.hortonworks.com:2181producer.type=sync 其中sa
浏览 1
提问于2015-03-20
得票数 4
2
回答
Azure连卡夫卡org.apache.
kafka
.common.errors.TimeoutException的一些记录
java
、
spring-boot
、
apache-kafka
、
azure-eventhub
有一个包含80到100个记录的ArrayList,试图将每个单独的记录(POJO,而不是整个列表)
发送
到
Kafka
主题(事件中心)。像每小时一样安排一个cron作业,将这些记录(POJO)
发送
到事件中心。能够看到
消息
被
发送
到eventhub,但在3到4成功运行之后,得到以下
异常
(这包括
发送
了几条
消息
,还有几条在下面的
异常
中失败) Expiring 14 record(s) for eventhubname-7分区-6使用spr
浏览 3
提问于2019-09-19
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Kafka是批量发送消息的?
一段解决kafka消息处理异常的经典对话
说说 MQ之Kafka(三)
Kafka的存储机制以及可靠性
Kafka解惑之Old Producer(4)——Case Analysis
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券