公司想制作网站吗,怎么做网站页面代码搜索,wordpress变慢了,在线网站开发培训问题来源
数据采集端正在调试#xff0c;相关人员告知已经将所有的推送端服务都停止了#xff0c;为何kafka上相关topic还能不断接收到消息#xff0c;要求排查是哪些ip还在推送数据。
问了一个DeepSeek#xff0c;得到的答案是Kafka本身并不直接记录或提供推送数据的客户…问题来源
数据采集端正在调试相关人员告知已经将所有的推送端服务都停止了为何kafka上相关topic还能不断接收到消息要求排查是哪些ip还在推送数据。
问了一个DeepSeek得到的答案是Kafka本身并不直接记录或提供推送数据的客户端IP信息。Kafka的设计理念是追求高吞吐量和低延迟因此没有内置记录客户端IP的功能。
提供了三种方案
1、使用网络层工具使用netstat或lsof命令来查看与Kafka broker建立的连接方法简单直接但缺点是这些IP地址无法与Kafka的客户端ID直接关联起来而且信息是实时的无法追溯历史记录。
2、临时修改Kafka日志级别修改log4j.properties文件将kafka.network.Processor的日志级别设置为DEBUG并重启这样Kafka会在日志中记录连接细节包括客户端的IP地址不过搜索结果提到这种方法会增加磁盘I/O和存储需求不建议长期使用。
3、使用抓包工具可以建立客户端ID与IP的关联关系这种方法需要交叉分析但能提供更丰富的信息。
可选方案
结合实际情况在不影响线上业务的情况下快速查出正在向broker发送消息的ip即可故选择第一个方案在kafka broker节点上使用
netstat -anp | grep :9092 | grep ESTABLISHED
或者
lsof -i :9092 | grep java
这里最终使用 netstat但是打印出来的消息较多里面包含集群中的其他broker、消费端的ip结合grep -v排除集群的其他ip和消费端ip 和 awk确定打印指定列
最终方案
netstat -anp | grep :9092 | grep ESTABLISHED | grep -v 消费端IP | grep -v 集群中其他节点IP | awk {print $5}
通过以上命令就可以快速找到推送端ip地址了
