John Roesler created KAFKA-8111:
-----------------------------------
Summary: KafkaProducer can't produce data
Key: KAFKA-8111
URL: https://issues.apache.org/jira/browse/KAFKA-8111
Project: Kafka
Issue Type: Bug
Components: clients, core
Affects Versions: 2.3.0
Reporter: John Roesler
Using a Producer from the current trunk (a6691fb79), I'm unable to produce data
to a 2.2 broker.
tl;dr;, I narrowed down the problem to
[https://github.com/apache/kafka/commit/a42f16f98] . My hypothesis is that some
part of that commit broke backward compatibility with older brokers.
Repro steps:
I'm using this Producer config:
{noformat}
final Properties properties = new Properties();
properties.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, BROKER);
properties.setProperty(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
StringSerializer.class.getCanonicalName());
properties.setProperty(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
StringSerializer.class.getCanonicalName());
return properties;{noformat}
# create a simple Producer to produce test data to a broker
# build against commmit a42f16f98
# start an older broker. (I was using 2.1, and someone else reproduced it with
2.2)
# run your producer and note that it doesn't produce data (seems to hang, I
see it produce 2 records in 1 minute)
# build against the predecessor commit 65aea1f36
# run your producer and note that it DOES produce data (I see it produce 1M
records every 15 second)
I've also confirmed that if I check out the current trunk (a6691fb79e2c55b3)
and revert a42f16f98, I also observe that it produces as expected (1M every 15
seconds).
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
