我正在使用安装在 ubuntu 框中的 kafka_2.10-0.8.1.1 的 java api，并在运行高级消费者时收到java.io.IOException: Connection reset by peer 。它适用于 kafka-console-consumer.sh 命令，但不适用于 java api
问问题
3352 次
我正在使用安装在 ubuntu 框中的 kafka_2.10-0.8.1.1 的 java api，并在运行高级消费者时收到java.io.IOException: Connection reset by peer 。它适用于 kafka-console-consumer.sh 命令，但不适用于 java api