kafka Log存储解析以及索引机制
本文设置到的配置项有
首先启动 kafka 集群,集群中有三台 Broker; 设置 3 个分区,3 个副本;
1 发送 topic 消息
启动之后kafka-client发送一个 topic 为消息szz-test-topic的消息
public static void main(String[] args) { Properties props = new Properties(); props.put("bootstrap.servers", "xxx1...