不会python,简单看对应的配置是话必要的参数都是对的,python发消息,没有发送成功,从几个点分析一下。
1、如果python和kafka集群不在同一台机器,kafka要设置listener对外暴露ip,不然连接都是不通的
2、python发送后等待一下,消息还在缓存中,还没来得急发送到kafka进程就结束了