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 (区),多个消费者消费是无法保证消息的消费顺序性的。 保证消息的顺序,那就用...