是在kafka的broker配置server.properties的listeners改为listeners=PLAINTEXT://kafka_ip:9092(kafka_ip要写具体IP,不要写localhost)