[jira] [Commented] (KAFKA-1620) Make kafka api protocol implementation public

[ https://issues.apache.org/jira/browse/KAFKA-1620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14136817#comment-14136817 ] Anton Karamanov commented on KAFKA-1620: Yes, it is actually one of the primary mo

Build failed in Jenkins: Kafka-trunk #267

See Changes: [junrao] trivial change to javadoc for makeLeaders(); patched by Lantao Jin -- [...truncated 2717 lines...] at sun.nio.ch.Net.bind(Native Method) at sun.nio.ch.ServerSock

[jira] [Resolved] (KAFKA-1635) Java doc of makeLeaders in ReplicaManager is wrong

[ https://issues.apache.org/jira/browse/KAFKA-1635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1635. Resolution: Fixed Fix Version/s: 0.8.2 Assignee: Lantao Jin (was: Neha Narkhede) Thanks for

Re: kafka 0.8.1: Producer.send() can block forever when a broker is down

Jack, If the broker is down, channel.connect() should throw an IOException, instead of blocking forever. In your case, is the broker host down? In that case, the connect call will likely wait for the default tcp connection timeout, which is 8+ mins. Thanks, Jun On Tue, Sep 16, 2014 at 5:43 PM,

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14136767#comment-14136767 ] Jun Rao commented on KAFKA-1282: Did you do "./gradlew jar" first? > Disconnect idle sock

[jira] [Commented] (KAFKA-1620) Make kafka api protocol implementation public

[ https://issues.apache.org/jira/browse/KAFKA-1620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14136754#comment-14136754 ] Jun Rao commented on KAFKA-1620: Thanks for the new patch. Similarly, do we need to make R

[jira] [Updated] (KAFKA-1637) SimpleConsumer.fetchOffset returns wrong error code when no offset exists for topic/partition/consumer group

[ https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amir Malekpour updated KAFKA-1637: -- Description: This concerns Kafka's Offset Fetch API: According to Kafka's current documentatio

[jira] [Updated] (KAFKA-1637) SimpleConsumer.fetchOffset returns wrong error code when no offset exists for topic/partition/consumer group

[ https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amir Malekpour updated KAFKA-1637: -- Summary: SimpleConsumer.fetchOffset returns wrong error code when no offset exists for topic/par

[jira] [Created] (KAFKA-1637) SimpleConsumer.fetchOffset returns wrong error code

Amir Malekpour created KAFKA-1637: - Summary: SimpleConsumer.fetchOffset returns wrong error code Key: KAFKA-1637 URL: https://issues.apache.org/jira/browse/KAFKA-1637 Project: Kafka Issue Typ

kafka 0.8.1: Producer.send() can block forever when a broker is down

We observe that when a broker is down, Producer.send() can get into a state where it will block forever, even when using the async producer. When a Producer first sends data, it fetches topic metadata from the broker cluster. To do this, it shuffles the list of hosts in the cluster, then iterat

Re: MBeans, dashes, underscores, and KAFKA-1481

HI Otis, What is migration path ? If topic with special chars exists already( ".","-","|" etc) in previous version of producer/consumer of Kafka, what happens after the upgrade new producer or consumer (kafka version) ? Also, in new producer API (Kafka Trunk), does this enforce the rule about c

Re: Review Request 25136: Patch for KAFKA-1610

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25136/ --- (Updated Sept. 16, 2014, 10:23 p.m.) Review request for kafka. Bugs: KAFKA-16

[jira] [Commented] (KAFKA-1610) Local modifications to collections generated from mapValues will be lost

[ https://issues.apache.org/jira/browse/KAFKA-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14136372#comment-14136372 ] Mayuresh Gharat commented on KAFKA-1610: Updated reviewboard https://reviews.apach

[jira] [Updated] (KAFKA-1610) Local modifications to collections generated from mapValues will be lost

[ https://issues.apache.org/jira/browse/KAFKA-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-1610: --- Attachment: KAFKA-1610_2014-09-16_15:23:27.patch > Local modifications to collections generate

[jira] [Commented] (KAFKA-1618) Exception thrown when running console producer with no port number for the broker

[ https://issues.apache.org/jira/browse/KAFKA-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14136362#comment-14136362 ] Gwen Shapira commented on KAFKA-1618: - I can't think of other client server system tha

[jira] [Updated] (KAFKA-1123) Broker IPv6 addresses parsed incorrectly

[ https://issues.apache.org/jira/browse/KAFKA-1123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Szafrański updated KAFKA-1123: Attachment: KAFKA-1123_v2.patch > Broker IPv6 addresses parsed incorrectly > ---

[jira] [Commented] (KAFKA-1624) building on JDK 8 fails

[ https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14136314#comment-14136314 ] Stevo Slavic commented on KAFKA-1624: - If I'm not mistaken, this error is caused by Sc

Re: MBeans, dashes, underscores, and KAFKA-1481

Hi, So maybe I should I should have asked the Q explicitly: Could we commit the patch from https://issues.apache.org/jira/browse/KAFKA-1481 now that, I hope, it's clear what problems the current MBean names can cause? Thanks, Otis -- Monitoring * Alerting * Anomaly Detection * Centralized Log Man

[jira] [Commented] (KAFKA-1618) Exception thrown when running console producer with no port number for the broker

[ https://issues.apache.org/jira/browse/KAFKA-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14136220#comment-14136220 ] Balaji Seshadri commented on KAFKA-1618: I agree with you [~jkreps] and [~nehanark

Re: Kafka Security

yup, yup, yup | done, done, done On Tue, Sep 16, 2014 at 1:54 PM, Jay Kreps wrote: > Hey Joe, > > Can you add me, Jun, and Neha too. > > -Jay > > On Tue, Sep 16, 2014 at 10:37 AM, Joe Stein wrote: > > Hi Andrew, yes the meeting took place and we plan to-do it every two > weeks > > (same bat tim

[jira] [Commented] (KAFKA-1618) Exception thrown when running console producer with no port number for the broker

[ https://issues.apache.org/jira/browse/KAFKA-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14136206#comment-14136206 ] Jay Kreps commented on KAFKA-1618: -- I think the problem with a default port is that yes,

Re: Kafka Security

Hey Joe, Can you add me, Jun, and Neha too. -Jay On Tue, Sep 16, 2014 at 10:37 AM, Joe Stein wrote: > Hi Andrew, yes the meeting took place and we plan to-do it every two weeks > (same bat time, same bat channel) moving forward. > > In attendance was Michael Herstine (LinkedIn), Arvind Mani (Li

Re: Review Request 25136: Patch for KAFKA-1610

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25136/#review53574 --- Looks got to me, just some minor comments below. Joel, could you tak

[jira] [Commented] (KAFKA-1610) Local modifications to collections generated from mapValues will be lost

[ https://issues.apache.org/jira/browse/KAFKA-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14136111#comment-14136111 ] Mayuresh Gharat commented on KAFKA-1610: Updated reviewboard https://reviews.apach

Re: Review Request 25136: Patch for KAFKA-1610

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25136/ --- (Updated Sept. 16, 2014, 8:08 p.m.) Review request for kafka. Bugs: KAFKA-161

[jira] [Updated] (KAFKA-1610) Local modifications to collections generated from mapValues will be lost

[ https://issues.apache.org/jira/browse/KAFKA-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-1610: --- Attachment: KAFKA-1610_2014-09-16_13:08:17.patch > Local modifications to collections generate

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: 1282_the_ultimate,_close_max_one_per_select.patch Attached patch: every select iterati

Re: Kafka Security

Oops, n/m for now, I'm non-local. Thanks, - Rob > On Sep 16, 2014, at 1:23 PM, Robert Withers > wrote: > > Same here, please. > > - Rob > >> On Sep 16, 2014, at 12:58 PM, Steve Morin wrote: >> >> Same here >> >>> On Sep 16, 2014, at 11:51, Joe Stein wrote: >>> >>> done >>> On Tue,

Re: Kafka Security

done, done On Tue, Sep 16, 2014 at 12:23 PM, Robert Withers wrote: > Same here, please. > > - Rob > > > On Sep 16, 2014, at 12:58 PM, Steve Morin wrote: > > > > Same here > > > >> On Sep 16, 2014, at 11:51, Joe Stein wrote: > >> > >> done > >> > >>> On Tue, Sep 16, 2014 at 11:46 AM, Joel Koshy

Re: Kafka Security

Same here, please. - Rob > On Sep 16, 2014, at 12:58 PM, Steve Morin wrote: > > Same here > >> On Sep 16, 2014, at 11:51, Joe Stein wrote: >> >> done >> >>> On Tue, Sep 16, 2014 at 11:46 AM, Joel Koshy wrote: >>> >>> Same here. >>> >>> Thanks, >>> >>> Joel >>> On Tue, Sep 16, 2014

[jira] [Updated] (KAFKA-1622) project shouldn't require signing to build

[ https://issues.apache.org/jira/browse/KAFKA-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1622: - Reviewer: Joe Stein > project shouldn't require signing to build > ---

Re: Kafka Security

Same here > On Sep 16, 2014, at 11:51, Joe Stein wrote: > > done > >> On Tue, Sep 16, 2014 at 11:46 AM, Joel Koshy wrote: >> >> Same here. >> >> Thanks, >> >> Joel >> >>> On Tue, Sep 16, 2014 at 06:43:22PM +, Todd Palino wrote: >>> Joe, can you add me to it as well? We obviously have s

[jira] [Updated] (KAFKA-1490) remove gradlew initial setup output from source distribution

[ https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1490: - Reviewer: Joe Stein > remove gradlew initial setup output from source distribution > -

Re: Review Request 25703: Patch for KAFKA-1490

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25703/ --- (Updated Сен. 16, 2014, 6:54 п.п.) Review request for kafka. Bugs: KAFKA-1490

Re: Kafka Security

done On Tue, Sep 16, 2014 at 11:46 AM, Joel Koshy wrote: > Same here. > > Thanks, > > Joel > > On Tue, Sep 16, 2014 at 06:43:22PM +, Todd Palino wrote: > > Joe, can you add me to it as well? We obviously have some interest in the > > discussion over here :) > > > > -Todd > > > > On 9/16/14,

Re: Kafka Security

done On Tue, Sep 16, 2014 at 11:48 AM, Andrew Psaltis wrote: > Hi Joe, > I am certainly interested. Can you please add me to the invite. > > Thanks, > Andrew > > On Tue, Sep 16, 2014 at 11:37 AM, Joe Stein wrote: > > > Hi Andrew, yes the meeting took place and we plan to-do it every two > weeks

Re: Kafka Security

Hi Joe, I am certainly interested. Can you please add me to the invite. Thanks, Andrew On Tue, Sep 16, 2014 at 11:37 AM, Joe Stein wrote: > Hi Andrew, yes the meeting took place and we plan to-do it every two weeks > (same bat time, same bat channel) moving forward. > > In attendance was Michae

[jira] [Commented] (KAFKA-1499) Broker-side compression configuration

[ https://issues.apache.org/jira/browse/KAFKA-1499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14135957#comment-14135957 ] Joel Koshy commented on KAFKA-1499: --- Sorry you are right - I mixed up the two. For some

Re: Kafka Security

Same here. Thanks, Joel On Tue, Sep 16, 2014 at 06:43:22PM +, Todd Palino wrote: > Joe, can you add me to it as well? We obviously have some interest in the > discussion over here :) > > -Todd > > On 9/16/14, 10:59 AM, "Joe Stein" wrote: > > >cool, I just added you to the invite > > > >O

Re: Kafka Security

=8^) done On Tue, Sep 16, 2014 at 11:43 AM, Todd Palino wrote: > Joe, can you add me to it as well? We obviously have some interest in the > discussion over here :) > > -Todd > > On 9/16/14, 10:59 AM, "Joe Stein" wrote: > > >cool, I just added you to the invite > > > >On Tue, Sep 16, 2014 at 1

Re: Kafka Security

Yup! On Tue, Sep 16, 2014 at 11:09 AM, Gwen Shapira wrote: > btw. I think we barely mention support of delegation tokens to allow > accessing Kafka from MR jobs, Storm, Samza, etc. > > Does it sound "in scope" for next week's agenda? > > Gwen > > On Tue, Sep 16, 2014 at 10:59 AM, Joe Stein wrot

Re: Kafka Security

Joe, can you add me to it as well? We obviously have some interest in the discussion over here :) -Todd On 9/16/14, 10:59 AM, "Joe Stein" wrote: >cool, I just added you to the invite > >On Tue, Sep 16, 2014 at 10:57 AM, Harsha wrote: > >> Hi Joe, >> I am interested in joining the effor

[jira] [Comment Edited] (KAFKA-1490) remove gradlew initial setup output from source distribution

[ https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14135928#comment-14135928 ] Ivan Lyutov edited comment on KAFKA-1490 at 9/16/14 6:41 PM: -

[jira] [Commented] (KAFKA-1490) remove gradlew initial setup output from source distribution

[ https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14135928#comment-14135928 ] Ivan Lyutov commented on KAFKA-1490: https://reviews.apache.org/r/25697/ > remove gra

[jira] [Created] (KAFKA-1636) High CPU in very active environment

Laurie Turner created KAFKA-1636: Summary: High CPU in very active environment Key: KAFKA-1636 URL: https://issues.apache.org/jira/browse/KAFKA-1636 Project: Kafka Issue Type: Bug C

[jira] [Updated] (KAFKA-1490) remove gradlew initial setup output from source distribution

[ https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Lyutov updated KAFKA-1490: --- Attachment: KAFKA-1490-2.patch Ok, I applied the patch which replays the functionality from Samza. >

Review Request 25703: Patch for KAFKA-1490

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25703/ --- Review request for kafka. Bugs: KAFKA-1490 https://issues.apache.org/jira/b

Re: [DISCUSS] 0.8.2 release branch, "unofficial" release candidates(s), 0.8.1.2 release

Hi All, Do we have any ballpark date on the release of 0.8.1.2 or 0.8.2. Thanks, Harsha On Thu, Sep 11, 2014, at 03:53 PM, Jay Kreps wrote: > I agree that a beta for 0.8.2 would be useful. It would also be good > to get it in production at LinkedIn before the final version. > > Sorry about st

Re: Kafka Security

btw. I think we barely mention support of delegation tokens to allow accessing Kafka from MR jobs, Storm, Samza, etc. Does it sound "in scope" for next week's agenda? Gwen On Tue, Sep 16, 2014 at 10:59 AM, Joe Stein wrote: > cool, I just added you to the invite > > On Tue, Sep 16, 2014 at 10:57

Re: Kafka Security

cool, I just added you to the invite On Tue, Sep 16, 2014 at 10:57 AM, Harsha wrote: > Hi Joe, > I am interested in joining the efforts. I went through apache > storm security with kerberos so I can bring some of that > experience into the discussion. > Thanks, > Harsha >

Re: Kafka Security

Hi Joe, I am interested in joining the efforts. I went through apache storm security with kerberos so I can bring some of that experience into the discussion. Thanks, Harsha On Tue, Sep 16, 2014, at 10:37 AM, Joe Stein wrote: > Hi Andrew, yes the meeting took place and we

[jira] [Commented] (KAFKA-1558) AdminUtils.deleteTopic does not work

[ https://issues.apache.org/jira/browse/KAFKA-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14135811#comment-14135811 ] Sriharsha Chintalapani commented on KAFKA-1558: --- Thanks [~junrao] Case 2 wor

Re: Kafka Security

Hi Andrew, yes the meeting took place and we plan to-do it every two weeks (same bat time, same bat channel) moving forward. In attendance was Michael Herstine (LinkedIn), Arvind Mani (LinkedIn), Gwen Shapira (Cloudera) and myself. Gwen updated the wiki after our discussion. Basically we are thi

[jira] [Commented] (KAFKA-1490) remove gradlew initial setup output from source distribution

[ https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14135765#comment-14135765 ] Joe Stein commented on KAFKA-1490: -- it is our problem, we need to resolve this we shouldn

[jira] [Commented] (KAFKA-1490) remove gradlew initial setup output from source distribution

[ https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14135760#comment-14135760 ] Ivan Lyutov commented on KAFKA-1490: Sorry guys for my previous post. I've confused ".

Re: （info）kafka truncate data of specific topic

Hi Jacky, Could you elaborate a bit on your use cases, like why you want to manually truncate logs? Kafka provide a set of configs for data retention based on data size and time (for example maintaining as much as 100 GB or up to 7 days of old data), would that be sufficient to you? Guozhang O

Kafka Security

Hi, I was just reading the recent changes to: https://cwiki.apache.org/confluence/display/KAFKA/Security after getting off a call about Kafka security and how we are jumping through hoops -- like having PGP keys on the consumers and producers to get around the lack of SSL support. Did the meeting t

[jira] [Commented] (KAFKA-1490) remove gradlew initial setup output from source distribution

[ https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14135703#comment-14135703 ] Ivan Lyutov commented on KAFKA-1490: I've deleted the gradlew output jar file and left

[jira] [Updated] (KAFKA-1490) remove gradlew initial setup output from source distribution

[ https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Lyutov updated KAFKA-1490: --- Attachment: KAFKA-1490.patch > remove gradlew initial setup output from source distribution >

Review Request 25697: Patch for KAFKA-1490

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25697/ --- Review request for kafka. Bugs: KAFKA-1490 https://issues.apache.org/jira/b

[jira] [Work started] (KAFKA-1490) remove gradlew initial setup output from source distribution

[ https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-1490 started by Ivan Lyutov. -- > remove gradlew initial setup output from source distribution >

[jira] [Commented] (KAFKA-1618) Exception thrown when running console producer with no port number for the broker

[ https://issues.apache.org/jira/browse/KAFKA-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14135588#comment-14135588 ] Balaji Seshadri commented on KAFKA-1618: ok if user doesn't give any port i will d

[jira] [Comment Edited] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14135561#comment-14135561 ] Nicolae Marasoiu edited comment on KAFKA-1282 at 9/16/14 3:00 PM: --

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14135561#comment-14135561 ] Nicolae Marasoiu commented on KAFKA-1282: - Hi, I have not made any patch yet, I wa

[jira] [Updated] (KAFKA-1635) Java doc of makeLeaders in ReplicaManager is wrong

[ https://issues.apache.org/jira/browse/KAFKA-1635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lantao Jin updated KAFKA-1635: -- Description: ReplicaManager have an incorrect java doc. The overview of function makeLeaders() is the

[jira] [Updated] (KAFKA-1635) Java doc of makeLeaders in ReplicaManager is wrong

[ https://issues.apache.org/jira/browse/KAFKA-1635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lantao Jin updated KAFKA-1635: -- Priority: Trivial (was: Minor) > Java doc of makeLeaders in ReplicaManager is wrong > -

[jira] [Commented] (KAFKA-1635) Java doc of makeLeaders in ReplicaManager is wrong

[ https://issues.apache.org/jira/browse/KAFKA-1635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14135135#comment-14135135 ] ASF GitHub Bot commented on KAFKA-1635: --- GitHub user LantaoJin opened a pull request

[GitHub] kafka pull request: KAFKA-1635: Fixed incorrect java doc of makeLe...

GitHub user LantaoJin opened a pull request: https://github.com/apache/kafka/pull/33 KAFKA-1635: Fixed incorrect java doc of makeLeaders() in ReplicaManager You can merge this pull request into a Git repository by running: $ git pull https://github.com/LantaoJin/kafka KAFKA-16

[jira] [Updated] (KAFKA-1620) Make kafka api protocol implementation public

[ https://issues.apache.org/jira/browse/KAFKA-1620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Karamanov updated KAFKA-1620: --- Attachment: 0002-KAFKA-1620-Make-kafka-api-protocol-implementation-pu.patch Not really. I just