Kafka Broker Offline Partitions Test:There are 3 offline partitions

May 26,2021 in Java,Kafka,问题记录 read (2451)

使用Offset Explorer 2.0新增Kafka topic,每个topic 32个partition,增加到第三个的时候显示创建成功，但是在topic列表中没有该topic,CDH上Kafka状态出现There are 3 offline partitions 在...

Kafka producer 和 consumer的简单使用

Jul 26,2017 in Kafka read (842)

http://kafka.apache.org/0101/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html

Jul 26,2017 in Flink,Kafka read (3937)

设置从指定offset开始读取在Flink 1.3.0及以上可以使用setStartFromSpecificOffsets设置从指定offset开始读取 Fault Tolerance 开启checkpoint即可 offset提交行为如果checkpoint被禁用,F...

Jul 13,2017 in Flink,Kafka read (1157)

使Flink输出的数据在多个partition中均匀分布 FlinkKafkaProducerBase的子类可以使用默认的KafkaPartitioner FixedPartitioner(只向partition 0中写数据)也可以使用自己定义的Partitioner(继承...

Dec 20,2016 in Kafka read (921)

依赖 Kafka需要依赖ZooKeeper,在搭建Kafka集群前先要搭建好ZooKeeper集群参考搭建ZooKeeper集群下载Kafka 下载地址我们使用的版本是:0.9.0.0 解压 tar -zxvf kafka_2.10-0.9.0.0.tgz 配...