You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Dong Lin <li...@gmail.com> on 2018/07/18 17:24:09 UTC

Re: [kafka-clients] Re: [VOTE] 1.1.1 RC3

Thank you all for taking time to certify and vote for the release!

This vote has passed with 10 +1 votes (3 bindings) and no 0 or -1 votes.


+1 vote from PMC Members:
- Jason Gustafson
- Rajini Sivaram
- Ismael Juma


+1 vote from Committers:
- Sriharsha Chintalapani
- Dong Lin

+1 vote from Community:
- Ted Yu
- Satish Duggana
- Jakub Scholz
- Brett Rann
- ManiKumar Reddy

0 vote: none

-1 vote: none

Vote thread: the thread is not found on http://markmail.org/message yet.
Will pose it when it is available.

I'll continue with the release process and the release announcement will
follow.


Cheers,
Dong


On Wed, Jul 18, 2018 at 7:46 AM, Ismael Juma <is...@juma.me.uk> wrote:

> +1 (binding)
>
> Verified signature of source artifact, ran tests and verified quickstart
> on source artifact with Java 8, verified quickstart on binary artifact (Scala
> 2.12) with Java 8, sanity checked release notes and Maven staging
> repository.
>
> Thanks for managing the release Dong!
>
> Ismael
>
> On Sun, Jul 8, 2018 at 3:36 PM Dong Lin <li...@gmail.com> wrote:
>
>> Hello Kafka users, developers and client-developers,
>>
>> This is the fourth candidate for release of Apache Kafka 1.1.1.
>>
>> Apache Kafka 1.1.1 is a bug-fix release for the 1.1 branch that was first
>> released with 1.1.0 about 3 months ago. We have fixed about 25 issues
>> since
>> that release. A few of the more significant fixes include:
>>
>> KAFKA-6925 <https://issues.apache.org/jira/browse/KAFKA-6925> - Fix
>> memory
>> leak in StreamsMetricsThreadImpl
>> KAFKA-6937 <https://issues.apache.org/jira/browse/KAFKA-6937> - In-sync
>> replica delayed during fetch if replica throttle is exceeded
>> KAFKA-6917 <https://issues.apache.org/jira/browse/KAFKA-6917> - Process
>> txn
>> completion asynchronously to avoid deadlock
>> KAFKA-6893 <https://issues.apache.org/jira/browse/KAFKA-6893> - Create
>> processors before starting acceptor to avoid ArithmeticException
>> KAFKA-6870 <https://issues.apache.org/jira/browse/KAFKA-6870> -
>> Fix ConcurrentModificationException in SampledStat
>> KAFKA-6878 <https://issues.apache.org/jira/browse/KAFKA-6878> - Fix
>> NullPointerException when querying global state store
>> KAFKA-6879 <https://issues.apache.org/jira/browse/KAFKA-6879> - Invoke
>> session init callbacks outside lock to avoid Controller deadlock
>> KAFKA-6857 <https://issues.apache.org/jira/browse/KAFKA-6857> - Prevent
>> follower from truncating to the wrong offset if undefined leader epoch is
>> requested
>> KAFKA-6854 <https://issues.apache.org/jira/browse/KAFKA-6854> - Log
>> cleaner
>> fails with transaction markers that are deleted during clean
>> KAFKA-6747 <https://issues.apache.org/jira/browse/KAFKA-6747> - Check
>> whether there is in-flight transaction before aborting transaction
>> KAFKA-6748 <https://issues.apache.org/jira/browse/KAFKA-6748> - Double
>> check before scheduling a new task after the punctuate call
>> KAFKA-6739 <https://issues.apache.org/jira/browse/KAFKA-6739> -
>> Fix IllegalArgumentException when down-converting from V2 to V0/V1
>> KAFKA-6728 <https://issues.apache.org/jira/browse/KAFKA-6728> -
>> Fix NullPointerException when instantiating the HeaderConverter
>>
>> Kafka 1.1.1 release plan:
>> https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+1.1.1
>>
>> Release notes for the 1.1.1 release:
>> http://home.apache.org/~lindong/kafka-1.1.1-rc3/RELEASE_NOTES.html
>>
>> *** Please download, test and vote by Thursday, July 12, 12pm PT ***
>>
>> Kafka's KEYS file containing PGP keys we use to sign the release:
>> http://kafka.apache.org/KEYS
>>
>> * Release artifacts to be voted upon (source and binary):
>> http://home.apache.org/~lindong/kafka-1.1.1-rc3/
>>
>> * Maven artifacts to be voted upon:
>> https://repository.apache.org/content/groups/staging/
>>
>> * Javadoc:
>> http://home.apache.org/~lindong/kafka-1.1.1-rc3/javadoc/
>>
>> * Tag to be voted upon (off 1.1 branch) is the 1.1.1-rc3 tag:
>> https://github.com/apache/kafka/tree/1.1.1-rc3
>>
>> * Documentation:
>> http://kafka.apache.org/11/documentation.html
>>
>> * Protocol:
>> http://kafka.apache.org/11/protocol.html
>>
>> * Successful Jenkins builds for the 1.1 branch:
>> Unit/integration tests: *https://builds.apache.org/job/kafka-1.1-jdk7/162
>> <https://builds.apache.org/job/kafka-1.1-jdk7/162>*
>> System tests:
>> https://jenkins.confluent.io/job/system-test-kafka/job/1.1/156/
>>
>> Please test and verify the release artifacts and submit a vote for this
>> RC,
>> or report any issues so we can fix them and get a new RC out ASAP.
>> Although
>> this release vote requires PMC votes to pass, testing, votes, and bug
>> reports are valuable and appreciated from everyone.
>>
>>
>> Regards,
>> Dong
>>
> --
> You received this message because you are subscribed to the Google Groups
> "kafka-clients" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to kafka-clients+unsubscribe@googlegroups.com.
> To post to this group, send email to kafka-clients@googlegroups.com.
> Visit this group at https://groups.google.com/group/kafka-clients.
> To view this discussion on the web visit https://groups.google.com/d/
> msgid/kafka-clients/CAD5tkZZbNe0FGwttWm-287rCyBGP%3DDsxmppouwr6CKf1RsUNRQ%
> 40mail.gmail.com
> <https://groups.google.com/d/msgid/kafka-clients/CAD5tkZZbNe0FGwttWm-287rCyBGP%3DDsxmppouwr6CKf1RsUNRQ%40mail.gmail.com?utm_medium=email&utm_source=footer>
> .
> For more options, visit https://groups.google.com/d/optout.
>

Re: [kafka-clients] Re: [VOTE] 1.1.1 RC3

Posted by "Matthias J. Sax" <ma...@confluent.io>.
Thanks Dong.

I am a little late, but +1, too.

 - verified signatures
 - build from sources
 - run unit test suite
 - run streams quickstart


Thanks for running the release!

-Matthias

On 7/18/18 10:24 AM, Dong Lin wrote:
> Thank you all for taking time to certify and vote for the release!
> 
> This vote has passed with 10 +1 votes (3 bindings) and no 0 or -1 votes.
> 
> 
> +1 vote from PMC Members:
> - Jason Gustafson
> - Rajini Sivaram
> - Ismael Juma
> 
> 
> +1 vote from Committers:
> - Sriharsha Chintalapani
> - Dong Lin
> 
> +1 vote from Community:
> - Ted Yu
> - Satish Duggana
> - Jakub Scholz
> - Brett Rann
> - ManiKumar Reddy
> 
> 0 vote: none
> 
> -1 vote: none
> 
> Vote thread: the thread is not found on http://markmail.org/message yet.
> Will pose it when it is available.
> 
> I'll continue with the release process and the release announcement will
> follow.
> 
> 
> Cheers,
> Dong
> 
> 
> On Wed, Jul 18, 2018 at 7:46 AM, Ismael Juma <ismael@juma.me.uk
> <ma...@juma.me.uk>> wrote:
> 
>     +1 (binding)
> 
>     Verified signature of source artifact, ran tests and verified
>     quickstart on source artifact with Java 8, verified quickstart on
>     binary artifact (Scala 2.12) with Java 8, sanity checked release
>     notes and Maven staging repository.
> 
>     Thanks for managing the release Dong!
> 
>     Ismael
> 
>     On Sun, Jul 8, 2018 at 3:36 PM Dong Lin <lindong28@gmail.com
>     <ma...@gmail.com>> wrote:
> 
>         Hello Kafka users, developers and client-developers,
> 
>         This is the fourth candidate for release of Apache Kafka 1.1.1.
> 
>         Apache Kafka 1.1.1 is a bug-fix release for the 1.1 branch that
>         was first
>         released with 1.1.0 about 3 months ago. We have fixed about 25
>         issues since
>         that release. A few of the more significant fixes include:
> 
>         KAFKA-6925 <https://issues.apache.org/jira/browse/KAFKA-6925
>         <https://issues.apache.org/jira/browse/KAFKA-6925>> - Fix memory
>         leak in StreamsMetricsThreadImpl
>         KAFKA-6937 <https://issues.apache.org/jira/browse/KAFKA-6937
>         <https://issues.apache.org/jira/browse/KAFKA-6937>> - In-sync
>         replica delayed during fetch if replica throttle is exceeded
>         KAFKA-6917 <https://issues.apache.org/jira/browse/KAFKA-6917
>         <https://issues.apache.org/jira/browse/KAFKA-6917>> - Process txn
>         completion asynchronously to avoid deadlock
>         KAFKA-6893 <https://issues.apache.org/jira/browse/KAFKA-6893
>         <https://issues.apache.org/jira/browse/KAFKA-6893>> - Create
>         processors before starting acceptor to avoid ArithmeticException
>         KAFKA-6870 <https://issues.apache.org/jira/browse/KAFKA-6870
>         <https://issues.apache.org/jira/browse/KAFKA-6870>> -
>         Fix ConcurrentModificationException in SampledStat
>         KAFKA-6878 <https://issues.apache.org/jira/browse/KAFKA-6878
>         <https://issues.apache.org/jira/browse/KAFKA-6878>> - Fix
>         NullPointerException when querying global state store
>         KAFKA-6879 <https://issues.apache.org/jira/browse/KAFKA-6879
>         <https://issues.apache.org/jira/browse/KAFKA-6879>> - Invoke
>         session init callbacks outside lock to avoid Controller deadlock
>         KAFKA-6857 <https://issues.apache.org/jira/browse/KAFKA-6857
>         <https://issues.apache.org/jira/browse/KAFKA-6857>> - Prevent
>         follower from truncating to the wrong offset if undefined leader
>         epoch is
>         requested
>         KAFKA-6854 <https://issues.apache.org/jira/browse/KAFKA-6854
>         <https://issues.apache.org/jira/browse/KAFKA-6854>> - Log cleaner
>         fails with transaction markers that are deleted during clean
>         KAFKA-6747 <https://issues.apache.org/jira/browse/KAFKA-6747
>         <https://issues.apache.org/jira/browse/KAFKA-6747>> - Check
>         whether there is in-flight transaction before aborting transaction
>         KAFKA-6748 <https://issues.apache.org/jira/browse/KAFKA-6748
>         <https://issues.apache.org/jira/browse/KAFKA-6748>> - Double
>         check before scheduling a new task after the punctuate call
>         KAFKA-6739 <https://issues.apache.org/jira/browse/KAFKA-6739
>         <https://issues.apache.org/jira/browse/KAFKA-6739>> -
>         Fix IllegalArgumentException when down-converting from V2 to V0/V1
>         KAFKA-6728 <https://issues.apache.org/jira/browse/KAFKA-6728
>         <https://issues.apache.org/jira/browse/KAFKA-6728>> -
>         Fix NullPointerException when instantiating the HeaderConverter
> 
>         Kafka 1.1.1 release plan:
>         https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+1.1.1
>         <https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+1.1.1>
> 
>         Release notes for the 1.1.1 release:
>         http://home.apache.org/~lindong/kafka-1.1.1-rc3/RELEASE_NOTES.html
>         <http://home.apache.org/%7Elindong/kafka-1.1.1-rc3/RELEASE_NOTES.html>
> 
>         *** Please download, test and vote by Thursday, July 12, 12pm PT ***
> 
>         Kafka's KEYS file containing PGP keys we use to sign the release:
>         http://kafka.apache.org/KEYS
> 
>         * Release artifacts to be voted upon (source and binary):
>         http://home.apache.org/~lindong/kafka-1.1.1-rc3/
>         <http://home.apache.org/%7Elindong/kafka-1.1.1-rc3/>
> 
>         * Maven artifacts to be voted upon:
>         https://repository.apache.org/content/groups/staging/
>         <https://repository.apache.org/content/groups/staging/>
> 
>         * Javadoc:
>         http://home.apache.org/~lindong/kafka-1.1.1-rc3/javadoc/
>         <http://home.apache.org/%7Elindong/kafka-1.1.1-rc3/javadoc/>
> 
>         * Tag to be voted upon (off 1.1 branch) is the 1.1.1-rc3 tag:
>         https://github.com/apache/kafka/tree/1.1.1-rc3
>         <https://github.com/apache/kafka/tree/1.1.1-rc3>
> 
>         * Documentation:
>         http://kafka.apache.org/11/documentation.html
>         <http://kafka.apache.org/11/documentation.html>
> 
>         * Protocol:
>         http://kafka.apache.org/11/protocol.html
>         <http://kafka.apache.org/11/protocol.html>
> 
>         * Successful Jenkins builds for the 1.1 branch:
>         Unit/integration tests:
>         *https://builds.apache.org/job/kafka-1.1-jdk7/162
>         <https://builds.apache.org/job/kafka-1.1-jdk7/162>
>         <https://builds.apache.org/job/kafka-1.1-jdk7/162
>         <https://builds.apache.org/job/kafka-1.1-jdk7/162>>*
>         System tests:
>         https://jenkins.confluent.io/job/system-test-kafka/job/1.1/156/
>         <https://jenkins.confluent.io/job/system-test-kafka/job/1.1/156/>
> 
>         Please test and verify the release artifacts and submit a vote
>         for this RC,
>         or report any issues so we can fix them and get a new RC out
>         ASAP. Although
>         this release vote requires PMC votes to pass, testing, votes,
>         and bug
>         reports are valuable and appreciated from everyone.
> 
> 
>         Regards,
>         Dong
> 
>     -- 
>     You received this message because you are subscribed to the Google
>     Groups "kafka-clients" group.
>     To unsubscribe from this group and stop receiving emails from it,
>     send an email to kafka-clients+unsubscribe@googlegroups.com
>     <ma...@googlegroups.com>.
>     To post to this group, send email to kafka-clients@googlegroups.com
>     <ma...@googlegroups.com>.
>     Visit this group at https://groups.google.com/group/kafka-clients
>     <https://groups.google.com/group/kafka-clients>.
>     To view this discussion on the web visit
>     https://groups.google.com/d/msgid/kafka-clients/CAD5tkZZbNe0FGwttWm-287rCyBGP%3DDsxmppouwr6CKf1RsUNRQ%40mail.gmail.com
>     <https://groups.google.com/d/msgid/kafka-clients/CAD5tkZZbNe0FGwttWm-287rCyBGP%3DDsxmppouwr6CKf1RsUNRQ%40mail.gmail.com?utm_medium=email&utm_source=footer>.
>     For more options, visit https://groups.google.com/d/optout
>     <https://groups.google.com/d/optout>.
> 
> 
> -- 
> You received this message because you are subscribed to the Google
> Groups "kafka-clients" group.
> To unsubscribe from this group and stop receiving emails from it, send
> an email to kafka-clients+unsubscribe@googlegroups.com
> <ma...@googlegroups.com>.
> To post to this group, send email to kafka-clients@googlegroups.com
> <ma...@googlegroups.com>.
> Visit this group at https://groups.google.com/group/kafka-clients.
> To view this discussion on the web visit
> https://groups.google.com/d/msgid/kafka-clients/CAAaarBZo8PtHLuKqeQd-QdEj1HSTt0c351yrO9QaK2OFm_vXvA%40mail.gmail.com
> <https://groups.google.com/d/msgid/kafka-clients/CAAaarBZo8PtHLuKqeQd-QdEj1HSTt0c351yrO9QaK2OFm_vXvA%40mail.gmail.com?utm_medium=email&utm_source=footer>.
> For more options, visit https://groups.google.com/d/optout.


Re: [kafka-clients] Re: [VOTE] 1.1.1 RC3

Posted by "Matthias J. Sax" <ma...@confluent.io>.
Thanks Dong.

I am a little late, but +1, too.

 - verified signatures
 - build from sources
 - run unit test suite
 - run streams quickstart


Thanks for running the release!

-Matthias

On 7/18/18 10:24 AM, Dong Lin wrote:
> Thank you all for taking time to certify and vote for the release!
> 
> This vote has passed with 10 +1 votes (3 bindings) and no 0 or -1 votes.
> 
> 
> +1 vote from PMC Members:
> - Jason Gustafson
> - Rajini Sivaram
> - Ismael Juma
> 
> 
> +1 vote from Committers:
> - Sriharsha Chintalapani
> - Dong Lin
> 
> +1 vote from Community:
> - Ted Yu
> - Satish Duggana
> - Jakub Scholz
> - Brett Rann
> - ManiKumar Reddy
> 
> 0 vote: none
> 
> -1 vote: none
> 
> Vote thread: the thread is not found on http://markmail.org/message yet.
> Will pose it when it is available.
> 
> I'll continue with the release process and the release announcement will
> follow.
> 
> 
> Cheers,
> Dong
> 
> 
> On Wed, Jul 18, 2018 at 7:46 AM, Ismael Juma <ismael@juma.me.uk
> <ma...@juma.me.uk>> wrote:
> 
>     +1 (binding)
> 
>     Verified signature of source artifact, ran tests and verified
>     quickstart on source artifact with Java 8, verified quickstart on
>     binary artifact (Scala 2.12) with Java 8, sanity checked release
>     notes and Maven staging repository.
> 
>     Thanks for managing the release Dong!
> 
>     Ismael
> 
>     On Sun, Jul 8, 2018 at 3:36 PM Dong Lin <lindong28@gmail.com
>     <ma...@gmail.com>> wrote:
> 
>         Hello Kafka users, developers and client-developers,
> 
>         This is the fourth candidate for release of Apache Kafka 1.1.1.
> 
>         Apache Kafka 1.1.1 is a bug-fix release for the 1.1 branch that
>         was first
>         released with 1.1.0 about 3 months ago. We have fixed about 25
>         issues since
>         that release. A few of the more significant fixes include:
> 
>         KAFKA-6925 <https://issues.apache.org/jira/browse/KAFKA-6925
>         <https://issues.apache.org/jira/browse/KAFKA-6925>> - Fix memory
>         leak in StreamsMetricsThreadImpl
>         KAFKA-6937 <https://issues.apache.org/jira/browse/KAFKA-6937
>         <https://issues.apache.org/jira/browse/KAFKA-6937>> - In-sync
>         replica delayed during fetch if replica throttle is exceeded
>         KAFKA-6917 <https://issues.apache.org/jira/browse/KAFKA-6917
>         <https://issues.apache.org/jira/browse/KAFKA-6917>> - Process txn
>         completion asynchronously to avoid deadlock
>         KAFKA-6893 <https://issues.apache.org/jira/browse/KAFKA-6893
>         <https://issues.apache.org/jira/browse/KAFKA-6893>> - Create
>         processors before starting acceptor to avoid ArithmeticException
>         KAFKA-6870 <https://issues.apache.org/jira/browse/KAFKA-6870
>         <https://issues.apache.org/jira/browse/KAFKA-6870>> -
>         Fix ConcurrentModificationException in SampledStat
>         KAFKA-6878 <https://issues.apache.org/jira/browse/KAFKA-6878
>         <https://issues.apache.org/jira/browse/KAFKA-6878>> - Fix
>         NullPointerException when querying global state store
>         KAFKA-6879 <https://issues.apache.org/jira/browse/KAFKA-6879
>         <https://issues.apache.org/jira/browse/KAFKA-6879>> - Invoke
>         session init callbacks outside lock to avoid Controller deadlock
>         KAFKA-6857 <https://issues.apache.org/jira/browse/KAFKA-6857
>         <https://issues.apache.org/jira/browse/KAFKA-6857>> - Prevent
>         follower from truncating to the wrong offset if undefined leader
>         epoch is
>         requested
>         KAFKA-6854 <https://issues.apache.org/jira/browse/KAFKA-6854
>         <https://issues.apache.org/jira/browse/KAFKA-6854>> - Log cleaner
>         fails with transaction markers that are deleted during clean
>         KAFKA-6747 <https://issues.apache.org/jira/browse/KAFKA-6747
>         <https://issues.apache.org/jira/browse/KAFKA-6747>> - Check
>         whether there is in-flight transaction before aborting transaction
>         KAFKA-6748 <https://issues.apache.org/jira/browse/KAFKA-6748
>         <https://issues.apache.org/jira/browse/KAFKA-6748>> - Double
>         check before scheduling a new task after the punctuate call
>         KAFKA-6739 <https://issues.apache.org/jira/browse/KAFKA-6739
>         <https://issues.apache.org/jira/browse/KAFKA-6739>> -
>         Fix IllegalArgumentException when down-converting from V2 to V0/V1
>         KAFKA-6728 <https://issues.apache.org/jira/browse/KAFKA-6728
>         <https://issues.apache.org/jira/browse/KAFKA-6728>> -
>         Fix NullPointerException when instantiating the HeaderConverter
> 
>         Kafka 1.1.1 release plan:
>         https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+1.1.1
>         <https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+1.1.1>
> 
>         Release notes for the 1.1.1 release:
>         http://home.apache.org/~lindong/kafka-1.1.1-rc3/RELEASE_NOTES.html
>         <http://home.apache.org/%7Elindong/kafka-1.1.1-rc3/RELEASE_NOTES.html>
> 
>         *** Please download, test and vote by Thursday, July 12, 12pm PT ***
> 
>         Kafka's KEYS file containing PGP keys we use to sign the release:
>         http://kafka.apache.org/KEYS
> 
>         * Release artifacts to be voted upon (source and binary):
>         http://home.apache.org/~lindong/kafka-1.1.1-rc3/
>         <http://home.apache.org/%7Elindong/kafka-1.1.1-rc3/>
> 
>         * Maven artifacts to be voted upon:
>         https://repository.apache.org/content/groups/staging/
>         <https://repository.apache.org/content/groups/staging/>
> 
>         * Javadoc:
>         http://home.apache.org/~lindong/kafka-1.1.1-rc3/javadoc/
>         <http://home.apache.org/%7Elindong/kafka-1.1.1-rc3/javadoc/>
> 
>         * Tag to be voted upon (off 1.1 branch) is the 1.1.1-rc3 tag:
>         https://github.com/apache/kafka/tree/1.1.1-rc3
>         <https://github.com/apache/kafka/tree/1.1.1-rc3>
> 
>         * Documentation:
>         http://kafka.apache.org/11/documentation.html
>         <http://kafka.apache.org/11/documentation.html>
> 
>         * Protocol:
>         http://kafka.apache.org/11/protocol.html
>         <http://kafka.apache.org/11/protocol.html>
> 
>         * Successful Jenkins builds for the 1.1 branch:
>         Unit/integration tests:
>         *https://builds.apache.org/job/kafka-1.1-jdk7/162
>         <https://builds.apache.org/job/kafka-1.1-jdk7/162>
>         <https://builds.apache.org/job/kafka-1.1-jdk7/162
>         <https://builds.apache.org/job/kafka-1.1-jdk7/162>>*
>         System tests:
>         https://jenkins.confluent.io/job/system-test-kafka/job/1.1/156/
>         <https://jenkins.confluent.io/job/system-test-kafka/job/1.1/156/>
> 
>         Please test and verify the release artifacts and submit a vote
>         for this RC,
>         or report any issues so we can fix them and get a new RC out
>         ASAP. Although
>         this release vote requires PMC votes to pass, testing, votes,
>         and bug
>         reports are valuable and appreciated from everyone.
> 
> 
>         Regards,
>         Dong
> 
>     -- 
>     You received this message because you are subscribed to the Google
>     Groups "kafka-clients" group.
>     To unsubscribe from this group and stop receiving emails from it,
>     send an email to kafka-clients+unsubscribe@googlegroups.com
>     <ma...@googlegroups.com>.
>     To post to this group, send email to kafka-clients@googlegroups.com
>     <ma...@googlegroups.com>.
>     Visit this group at https://groups.google.com/group/kafka-clients
>     <https://groups.google.com/group/kafka-clients>.
>     To view this discussion on the web visit
>     https://groups.google.com/d/msgid/kafka-clients/CAD5tkZZbNe0FGwttWm-287rCyBGP%3DDsxmppouwr6CKf1RsUNRQ%40mail.gmail.com
>     <https://groups.google.com/d/msgid/kafka-clients/CAD5tkZZbNe0FGwttWm-287rCyBGP%3DDsxmppouwr6CKf1RsUNRQ%40mail.gmail.com?utm_medium=email&utm_source=footer>.
>     For more options, visit https://groups.google.com/d/optout
>     <https://groups.google.com/d/optout>.
> 
> 
> -- 
> You received this message because you are subscribed to the Google
> Groups "kafka-clients" group.
> To unsubscribe from this group and stop receiving emails from it, send
> an email to kafka-clients+unsubscribe@googlegroups.com
> <ma...@googlegroups.com>.
> To post to this group, send email to kafka-clients@googlegroups.com
> <ma...@googlegroups.com>.
> Visit this group at https://groups.google.com/group/kafka-clients.
> To view this discussion on the web visit
> https://groups.google.com/d/msgid/kafka-clients/CAAaarBZo8PtHLuKqeQd-QdEj1HSTt0c351yrO9QaK2OFm_vXvA%40mail.gmail.com
> <https://groups.google.com/d/msgid/kafka-clients/CAAaarBZo8PtHLuKqeQd-QdEj1HSTt0c351yrO9QaK2OFm_vXvA%40mail.gmail.com?utm_medium=email&utm_source=footer>.
> For more options, visit https://groups.google.com/d/optout.