[jira] [Resolved] (KAFKA-8111) KafkaProducer can't produce data

["Rajini Sivaram (JIRA)" <ji...@apache.org>]

     [ 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)