Kafka集群的数据传送方法和装置
基本信息
| 申请号 | CN201710090095.4 | 申请日 | - |
| 公开（公告）号 | CN106936896B | 公开（公告）日 | 2019-06-25 |
| 申请公布号 | CN106936896B | 申请公布日 | 2019-06-25 |
| 分类号 | H04L29/08（2006.01）I | 分类 | 电通信技术; |
| 发明人 | 杨玉奇; 杨从安; 张宇平 | 申请（专利权）人 | 北京数字联盟网络科技有限公司 |
| 代理机构 | 北京智汇东方知识产权代理事务所（普通合伙） | 代理人 | 北京数字联盟网络科技有限公司 |
| 地址 | 100088 北京市海淀区知春路6号（锦秋国际大厦）16层B01 | ||
| 法律状态 | - | ||
摘要
| 摘要 | 本发明提供了一种Kafka集群的数据传送方法和装置。其中Kafka集群的数据传送方法，该方法包括：调用预设的Kafka连接状态接口，以利用Kafka连接状态接口获取Kafka集群的连接状态标识；识别连接状态标识对应的Kafka集群的数据连接状态；在数据连接状态为Kafka集群中所有服务器均无法连接的情况下，停止向Kafka集群传送数据。通过Kafka连接状态接口可以判断Kafka集群的连接状态，可以及时发现Kafka集群的异常连接情况，并停止进行数据传输，降低缓存中的本地消息队列中数据丢失的风险，从而提高了Kafka集群的可靠性。 |
