Loading...
Filebeat 输出kafka遇到的问题1、filebeat与kafka版本问题错误信息：2022-03-20T14:55:02.198+0800 INFO kafka/log.go:53 producer/broker/544 starting up 2022-03-20T14:55:02.198+0800 INFO kafka/log.go:53 produce...
疑惑查看项目启动类并没有配置@ComponentScan，很疑惑为什么能够扫描到每一个模块注入到Spring容器。发现深入到每个模块之后发现，在每一个模块资源文件之下都有一个路径META-INF/spring.factories，在这个配置文件下加载了一个配置类，配置类配置了扫描该模块的注解@ComponentScan实现相关注入。Java SPI扩展机制Java SPI约定SpringBo...
使用logstash遇到的一些问题1、logstash kafka input配置想要使用多个 logstash 端协同消费同一个 topic 的话，那么需要把两个或是多个 logstash 消费端配置成相同的 group_id 和 topic_id， 但是前提是要把相应的 topic 分多个 partitions (区)，多个消费者消费是无法保证消息的消费顺序性的。 保证消息的顺序，那就用...