我在两个不同的VM中运行Kafka实例 . 我可以使用spring kafka-template向vm-1中运行的Kafka发送消息,但是在向vm-2中运行的kafka发送消息时,我得到以下异常:

2018-04-19 15:12:57 [kafka-producer-network-thread | producer-1] ERROR osksLoggingProducerListener - 发送带有key ='xxxx'和payload ='{79,98,106,1,4,29,97,118,114,111,46,115,99的消息时抛出异常,104,101,109,97,-28,51,123,34,116,12 ......'到主题xxxxxx-v1:org.apache.kafka.common.errors.TimeoutException:过期1条记录xxxxxx-v1-3:自批量创建加上延迟时间以来已经过了60043毫秒

Producer configuration

config.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, x.x.x.x:port);
config.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
config.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, ByteArraySerializer.class);
config.put(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG, 60000);
config.put(ProducerConfig.BATCH_SIZE_CONFIG, 1048576);
config.put(ProducerConfig.LINGER_MS_CONFIG, 100);
config.put(ProducerConfig.MAX_REQUEST_SIZE_CONFIG, 10485760);
config.put(ProducerConfig.ACKS_CONFIG, "all");

我可以telnet到两个虚拟机并ping它们 .