记录一下zk，kafka联合elk收集日志

安装zk，kafka，和elk。

kafka命令

1. bin/kafka-server-stop.sh 停止kafka

2. bin/kafka-server-start.sh config/server.properties 启动kafka

3. ./kafka-console-consumer.sh --bootstrap-server 10.20.10.124:9092 --topic test1 --from-beginning  查看接受到的该test的信息

zookeeper命令

1. 启动ZK服务:       sh bin/zkServer.sh start

2. 查看ZK服务状态: sh bin/zkServer.sh status

3. 停止ZK服务:       sh bin/zkServer.sh stop

4. 重启ZK服务:       sh bin/zkServer.sh restart

项目里测试kafka连接是否成功

项目引入kafka包

    org.springframework.kafka
    spring-kafka

yml里配置数据

spring:
  kafka:
    bootstrap-servers: 10.20.10.124:9092
    #生产者的配置，大部分我们可以使用默认的，这里列出几个比较重要的属性
    producer:
      batch-size: 128
      retries: 3
      buffer-memory: 40960
      acks: all
      properties:
        linger.ms: 10

生产者：private final KafkaTemplate kafkaTemplate;

kafkaTemplate.send("test1","我的springboot测试消息2");

消费者：

@KafkaListener(groupId = "test",topics = "test1")
public void onMessage1(ConsumerRecord record) {
    // 消费的哪个topic、partition的消息,打印出消息内容
    System.out.println("简单消费：" + record.topic() + "-" + record.partition() + "-" + record.value());

}

按照网上操作来，没啥大问题。