[ https://issues.apache.org/jira/browse/KAFKA-8111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Rajini Sivaram resolved KAFKA-8111. ----------------------------------- Resolution: Fixed Reviewer: Manikumar Fix Version/s: 2.3.0 > 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 > Fix For: 2.3.0 > > > 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)