蒋志伟

如果安装的是apache官网的kafka,那么进入机器如下对应的目录: 标注的 1.0.0就是 kafka的版本  

执行kafka-replay-log-producer.sh --broker-list hadoop1:9092 --zookeeper hadoop1:2181 --inputtopic test --outputtopic test2 会报错 ERROR consumer thread timing out (kafka.tools.ReplayLogProducer$ZKConsum...

  刷盘方式 同步刷盘：在消息到达MQ后，RocketMQ需要将数据持久化，同步刷盘是指数据到达内存之后，必须刷到commitlog日志之后才算成功，然后返回producer数据已经发送成功。 异步刷盘：，同步刷盘是指数据到达内存之后,返回producer说数据已经发送成功。，然后再写入commitlog日志。 commitlog： commitlog就是来存储所有的元信息，包含消息体...

只需要在代码中加入 props.put("auto.offset.reset", "earliest"); props.put("group.id", UUID.randomUUID().toString());  完整例子 //1、准备配置文件 Properties props = new Properties(); props.put("boo...

一个像kafka模拟生产者发送消息的程序，  //1、准备配置文件        Properties props = new Properties();        props.put("bootstrap.servers", "hadoop1:9092");        props.put("acks", "all");        props.put("retries", 0); ...