Kafka分布式容器数据发布实战 二

实验简介

通过为Nginx容器添加KafkaProducer 收集nginx日志到一个统一的日志收集容器中，日志收集容器中包含一个KafkaConsumer，并且通过一个KafkaServer进行中继。Nginx容器共有三个。

实验准备

1个KafkaProducerAPI 的Java 客户端，1个KafkaConsumerAPI的Java客户端，1个经过定制的Nginx容器镜像。

实验步骤

• 编写KafkaProducer JAVA文件并且生成可执行jar文件，进行测试。

参考文档：

https://blog.****.net/galen2016/article/details/80752147

• 编写KafkaConsumer JAVA文件并且生成可执行jar文件，进行测试。

参考文档：

https://blog.****.net/galen2016/article/details/80752147

• 编写一个文件修改监听器 JAVA文件并且完成测试。

​​​​​​​​​​​​​​

• 集成文件修改监听器与KafkaProducer JAVA文件。

​​​​​​​

• 上线测试，部署KafkaServer*1、KafkaConsumer*1、NginxWithLogMonitor*1。

​​​​​​​

• 编写日志存储JAVA文件，并与KafkaConsumer集成。

​​​​​​​

• 部署NginxWithLogMonitor*3、KafkaConsumer*1、KafkaServer*1。

1、重新打包 镜像

2、部署容器

.3、访问nginx端口

4、查看kafkaconsumer容器日志

如果你有其他见解或者问题，请留言给我，我会尽快答复。谢谢大家的观看。

java及容器文件项目地址：https://gitee.com/chinakun/kafka_practice