You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/03/15 18:09:00 UTC

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

    [ https://issues.apache.org/jira/browse/KAFKA-8111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793837#comment-16793837 ] 

ASF GitHub Bot commented on KAFKA-8111:
---------------------------------------

rajinisivaram commented on pull request #6451: KAFKA-8111; Set min and max versions for Metadata requests
URL: https://github.com/apache/kafka/pull/6451
 
 
   
   ### Committer Checklist (excluded from commit message)
   - [ ] Verify design and implementation 
   - [ ] Verify test coverage and CI build status
   - [ ] Verify documentation (including upgrade notes)
   
 
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


> 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: Major
>
> 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)