kafka是一种高吞吐量的分布式发布订阅消息系统,她有如下特性: 通过O(1)的磁盘数据结构提供消息的持久化,这种结构对于即使数以TB的消息存储也能够保持长时间的稳定性能。 高吞吐量:即使是非常普通的硬件kafka也可以支持每秒数十万...
  • 0投票
  • 0回答
  • 21浏览

flink 并发读取kafka数据问题

各位,小弟请教个问题: 你好,想跟你请教个问题: 各位好:刚开始学习flink,有个问题请教:  我搭建了有5个节点的flink集群(standalone...
  • 0投票
  • 0回答
  • 11浏览

spring-integration-kafka集成问题

遇到的问题很奇怪,在windows下跑的好好的,但是在linux下启动报了个这样的错,不知道大家有没遇到过,网上找了说是kafka-clients版本不对...
  • 0投票
  • 1回答
  • 1K+浏览

kafka-connect-hdfs如何使用

@卢禹 你好,想跟你请教个问题:这个hdfs的connector下载后如何使用,没有介绍怎么用。 地址:https://github.com/conflu...
  • 0投票
  • 3回答
  • 2K+浏览

kafka消息丢失现象

先是部署了5台机器,每个机器都是10个分区,一台笔记本作为客户端,使用一个group,采用50线程接收,但是经常出现消息不能全部接收,即有时候能接到有时候...
  • 0投票
  • 4已采纳
  • 404浏览

kafka消费数据,一段时间后无法消费,需要重换groupId

将图片数据base64以后,写入kafka,然后用java 写了一个消费代码,开始跑,没有问题,可以消费到数据,并处理,但是最近发现,跑一段时间无法消费到...
  • 0投票
  • 4回答
  • 8K+浏览

kafka集群出现奇怪的现象

各位好:  最近在研究kafka的时候遇到一个奇怪的现象,还请不灵赐教! 1:当集群环境运行一段时间后会出现奇怪错误,zookeeper无法连接到其中一个...
  • 0投票
  • 0回答
  • 596浏览

kafka批量消费数据

java kafka客户端如何批量消费数据? 以下是消费代码 Properties props = new Properties(); props....
顶部