[
https://issues.apache.org/jira/browse/KAFKA-8111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-8111:
--------------------------------
Labels: blocker (was: )
> 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
> Assignee: Rajini Sivaram
> Priority: Critical
> Labels: blocker
>
> 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)
