Intercetpor的实现接口是org.apache.kafka.clients.producer.ProducerInterceptor。

优点： （1）解耦 （2）冗余（备份） （3）扩展性 （4）灵活性、峰值处理能力 （5）可恢复性（冗余） （6）顺序保证（队列） （7）缓冲（冗余） （8）异步通信（宕机）...

修改Kafka的advertised.listeners要指向虚拟机地址IP 上传dockerfile 文件

最近项目中使用的数据接口服务如TSDB，kafka，订阅服务等在挂掉几次后，为了防止影响主系统的使用，我们要进行守护进程，在进程挂掉后自动拉起。

队列（Queue）是一种遵从先进先出（First in, first out。简称 FIFO）原则的有序集合。 它和栈的不同点是栈是先进后出的，队列是先进先出的，栈都是在一端进与出，而队列是在一端进在另一端出。栈的删除操作在表尾进行，队列的删除操...

参考了一些 https://www.likecs.com/show-152186.html 中的信息，去 https://github.com/big-data-europe/docker-hive 中把下载 docker-compose.yml 和 hadoop-hive.env 放在 docker-hive路径下，......

消息队列是存储数据的一个中间件，可以理解为一个容器。生产者生产消息投递 到队列中，消费者可以拉取消息进行消费，如果消费者目前没有消费的打算，则消息队列会保留消息，直到消费者有消费的打算。...

分区挂载格式要用盘符去挂载不要用UUID去挂载，不然做好镜像在还原的时候会识别不了vi修改分区挂载文件：/etc/fstab改成对应的盘符

在资料中有一个kafka_server.log.tar.gz压缩包，里面包含了很多的Kafka服务器日志，现在我们为了通过在Elasticsearch中快速查询这些日志，定位问题。我们需要用FileBeats将日志数据上传到Elasticsearch中。...

1.在Activity中动态注册广播时，调用registerReceiver方法,会调用到ContextWrapper的registerReceiver方法：