当kafka producer在线或离线时获取通知
当 Kafka producer 在线或离线时获取通知，可以通过以下方式实现：
- 使用心跳机制：Kafka producer可以定期向Kafka broker发送心跳消息，以表明其在线状态。如果在一定时间内未收到心跳消息，Kafka broker可以将该producer标记为离线状态，并触发相应的通知机制。
- 使用回调函数：Kafka producer可以注册一个回调函数，用于处理发送消息的结果。当producer成功发送消息时，回调函数将被调用，可以在回调函数中进行相应的通知操作。如果producer在发送消息时遇到错误，也可以在回调函数中进行错误处理和通知。
- 使用监控工具：可以使用监控工具来实时监测Kafka producer的状态。监控工具可以定期检查producer的在线状态，并在producer离线时发送通知。腾讯云提供了云监控服务（https://cloud.tencent.com/product/monitoring）可以用于监控Kafka producer的状态。
- 使用消息队列：可以将Kafka producer的状态信息发送到一个专门的消息队列中，然后由其他系统或应用程序订阅该消息队列，实现离线时的通知功能。腾讯云提供了消息队列CMQ（https://cloud.tencent.com/product/cmq）可以用于实现消息的发布和订阅。
总结起来，当Kafka producer在线或离线时获取通知的方法包括使用心跳机制、回调函数、监控工具和消息队列。这些方法可以根据具体需求和场景选择使用。
相关·内容
此外，我将通过kafka从我的rest(消费者)中获得大约40-50个swing独立应用(生产者)的数据。我需要为这些swing应用程序实现在线状态。基本上，我需要知道哪一个swing应用程序何时脱机或重新联机。有没有办法实现这一点？如果用kafka不能做到这一点，你能推荐一些其他的交流方式吗？说明:我所说的在线状态是指安装了swing应用程序的设备是否有互联网连接。Swing应用程序将安装在远程位置的大约40-50台设备上。
浏览 17提问于2020-08-06得票数 2
回答已采纳
我正在使用kafka控制台工具，并试图设置它，如果至少有一个kafka服务器实例仍然在线，仍然可以发送和接收消息，同时使用复制。配置:动物园管理员(本地宿主:2181)，kafka1 (本地宿主:9092)，kafka2 (本地宿主:9093)，producer1 (本地宿主:9092)，producer2(本地宿主:9093)但是，如果kafka1离线而kafka2在线，发送的消息就会被交换--抵
浏览 6提问于2017-02-28得票数 0
回答已采纳
在这种情况下，如果我想要Kafka，有没有可能让消费者只在生产者产生消息时才开始消费数据。我知道生产者和消费者是分离的。但是，使用Kafka处理这种用例的最佳方式是什么呢？
浏览 3提问于2020-08-07得票数 0
如果有3个Kafka brokers( kafka1，kafka2，kafka3)(它们在同一个Kafka集群中)和topic=test(replication=2)，kafka1有领导者分区，kafka2如果producer将数据发送到kafka3，那么数据如何存储在kafka1和Kafka2中？我听说，如果producer向kafka3发送数据，那么zooke
浏览 12提问于2020-06-27得票数 0
:outbound-channel-adapter id="kafkaOutboundChannelAdapter" producer-properties="producerProperties">
<int-kafk
浏览 1提问于2015-12-19得票数 1
消息由kafka-console-producer用acks=all生成，由kafka-console-consumer读取。/kafka-console-producer.sh --broker-list localhost:9092 --topic insync --producer.config ../config/producer.propertiesbootstrap.serv
浏览 1提问于2019-11-24得票数 1
回答已采纳
5回答
我在.NET核心Web API中有聊天服务，当客户在线时，通过Signal R处理聊天消息。
此外，我有移动客户端(android/apple)，当客户端处于脱机模式时，我需要处理发送的消息。我知道客户端是否离线/在线。因此，当客户端离线时，我想向苹果/安卓推送通知服务器发送消息，这样它就可以通知设备有新消息。有哪些选项可以将net core Web
浏览 6提问于2018-10-02得票数 6
在我们的项目中，我们需要通过许多线程定期从第三方获取数据，然后将这些数据推送给Kafka。如果目前无法使用Kafka服务器，则应该终止流，在下一次预定执行过程中应该丢失并重新获取获取的数据。设置spring.kafka.producer.retries: 0或spring.kafka.producer.acks: 0原因(不是完全堆栈跟踪)：
Caused by: org.apache.kafka.
浏览 1提问于2018-07-16得票数 2
我正在设计一个应用程序，需要知道哪些用户是在线或离线。每个用户都可以通知服务器他是在线还是离线，然后我可以从服务器获取该信息。
问题是，android中是否有一个标准可以将用户标记为在线或离线。一种解决方案是，如果应用程序正在运行，则用户处于在线状态；如果应用程序强制停止或未运行，则用户处于离线状态。那么，在我的应用程序中，我如何知道应用程序正在停止？如果上面的方
浏览 5提问于2013-11-14得票数 2
1回答
现在我被困在如何使用openfire服务器实现通知的问题上，特别是用户离线，尝试了google，但没有帮助。如果能帮上忙的话...
浏览 20提问于2016-08-22得票数 0
4回答
我坚持一个观点，我也在离线管理我的应用程序。我第一次从webservices获取所有个人资料数据并将其路径存储到sqlite中时，我在更新这些数据时遇到了问题，比如如果图像被更改，我应该如何通知我的应用程序，我在谷歌上搜索它，唯一的解决方案是当记录更新时向应用程序发送推送通知如果用户不允许推送通知怎么办？
有没有其他的解决方案可以离线管理app，只在在线数据库中记录发生变化时才进行更新？
浏览 1提问于2016-02-18得票数 3
这是系统的总体架构:生产者-> Kafka ->消费者->数据库
假设生产者向Kafka发送一条消息，该消息的目的是在数据库中进行特定的查询并检索查询结果。然而，众所周知，卡夫卡是一个异步系统。
浏览 8提问于2020-01-02得票数 3
回答已采纳
我正在使用：
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test.Zookeeper和kafka服务器运行良好。我正在使用Mac。可能的问题是什么。我正在关注Apache Kafka文档。
浏览 2提问于2016-07-11得票数 2
我已经看到了文档的这一部分()：
$ bin/kafka-topics.sh -创建--动物园管理员本地主机:2181-复制-因子1-分区1-主题测试$ bin/kafka-topics.sh -列表-动物园管理员本地主机:2181测试
或者，也可以将您的代理配置为在向不存在的主题发布时自动创建主题
浏览 1提问于2018-12-28得票数 1
1回答
Django频道-实时通知
、、、、
假设，如果用户在线，websocket连接被创建，并且用户将获得所有实时通知。但是，如果用户离线，websocket连接中断，那么如果在离线期间必须发送任何实时通知，如果用户再次联机(即当该用户再次建立websocket连接时)，是否会再次发送？？
浏览 16提问于2021-03-18得票数 0
在线为主题添加分区后，kafka消费者停止读取消息，不会抛出异常。消费者只是阻塞。每次我们都必须重启消费者。我认为这是不合理的，我找不到任何关于它的文档。此外，当处理消息时出现错误时，消费者线程将不会恢复。我们的消费者读取消息并将其插入到MySql中。一旦网络出现故障，消费者就无法连接到MySql，然后它就会阻塞并停止读取消息，直到我们重新启动它。当经纪人关闭时，kafka生产者无法发送消息。
我们有一个包含3个分区和2个副本的主题。kafka集群有3
浏览 57提问于2016-03-20得票数 4
我的目标是从非文件来源(即在程序中生成或通过API发送)获取数据，并将其发送到spark流。KafkaProducer> producer = KafkaProducer(bootstrap_servers='localhost:9092', value_serializer=lambda v: json.dumps(v).encode('utf-8'))
> producer.send(topic = 'my-topic&#
浏览 14提问于2017-07-09得票数 0
回答已采纳
2回答
我目前正在配置kafka连接(使用)，我使用环境变量成功地将它连接到Kafka： -v bbbbbb.jks:bbbbbb.jks \ -e HOST_NAME="AAAAAA-kafka-connect" \
-e CONNECT_SASL_JAAS_CONFIG=&q
浏览 14提问于2022-05-24得票数 0
回答已采纳
我正在使用socket.io离线管理用户在线。当另一个用户离线时，我需要通知特定的用户。当用户在线或用户离线时，请帮助我摆脱这些UserOnline管理。
浏览 0提问于2019-12-19得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
