[jira] [Commented] (KAFKA-1693) Issue sending more messages to single Kafka server (Load testing for Kafka transport)

[ https://issues.apache.org/jira/browse/KAFKA-1693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14166538#comment-14166538 ] rajendram kathees commented on KAFKA-1693: -- Thanks for quick response. I changed

[jira] [Comment Edited] (KAFKA-1693) Issue sending more messages to single Kafka server (Load testing for Kafka transport)

[ https://issues.apache.org/jira/browse/KAFKA-1693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14166538#comment-14166538 ] rajendram kathees edited comment on KAFKA-1693 at 10/10/14 7:58 AM:

[jira] [Comment Edited] (KAFKA-1693) Issue sending more messages to single Kafka server (Load testing for Kafka transport)

[ https://issues.apache.org/jira/browse/KAFKA-1693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14166538#comment-14166538 ] rajendram kathees edited comment on KAFKA-1693 at 10/10/14 8:10 AM:

[jira] [Issue Comment Deleted] (KAFKA-1328) Add new consumer APIs

[ https://issues.apache.org/jira/browse/KAFKA-1328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stevo Slavic updated KAFKA-1328: Comment: was deleted (was: Affects 0.9.0 ?!) > Add new consumer APIs > - > >

[jira] [Commented] (KAFKA-784) creating topic without partitions, deleting then creating with partition causes errors in 'kafka-list-topic'

[ https://issues.apache.org/jira/browse/KAFKA-784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14166709#comment-14166709 ] Ahmet AKYOL commented on KAFKA-784: --- happy to hear that. I was using this version: ./kaf

[jira] [Assigned] (KAFKA-1691) new java consumer needs ssl support as a client

[ https://issues.apache.org/jira/browse/KAFKA-1691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Lyutov reassigned KAFKA-1691: -- Assignee: Ivan Lyutov > new java consumer needs ssl support as a client > -

[jira] [Assigned] (KAFKA-1690) new java producer needs ssl support as a client

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Lyutov reassigned KAFKA-1690: -- Assignee: Ivan Lyutov > new java producer needs ssl support as a client > -

[jira] [Commented] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14166880#comment-14166880 ] Joe Stein commented on KAFKA-1477: -- Jun, Getting this to work in the new (java) client

[jira] [Updated] (KAFKA-784) creating topic without partitions, deleting then creating with partition causes errors in 'kafka-list-topic'

[ https://issues.apache.org/jira/browse/KAFKA-784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-784: - Fix Version/s: 0.8.2 > creating topic without partitions, deleting then creating wi

[jira] [Resolved] (KAFKA-784) creating topic without partitions, deleting then creating with partition causes errors in 'kafka-list-topic'

[ https://issues.apache.org/jira/browse/KAFKA-784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani resolved KAFKA-784. -- Resolution: Fixed > creating topic without partitions, deleting then creating wit

[jira] [Commented] (KAFKA-784) creating topic without partitions, deleting then creating with partition causes errors in 'kafka-list-topic'

[ https://issues.apache.org/jira/browse/KAFKA-784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14166988#comment-14166988 ] Sriharsha Chintalapani commented on KAFKA-784: -- [~liqusha] with kafka 0.8.2 br

Review Request 26560: Patch for KAFKA-1305

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

[jira] [Commented] (KAFKA-1305) Controller can hang on controlled shutdown with auto leader balance enabled

[ https://issues.apache.org/jira/browse/KAFKA-1305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167017#comment-14167017 ] Sriharsha Chintalapani commented on KAFKA-1305: --- Created reviewboard https:/

[jira] [Updated] (KAFKA-1305) Controller can hang on controlled shutdown with auto leader balance enabled

[ https://issues.apache.org/jira/browse/KAFKA-1305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1305: -- Attachment: KAFKA-1305.patch > Controller can hang on controlled shutdown with a

[jira] [Updated] (KAFKA-1305) Controller can hang on controlled shutdown with auto leader balance enabled

[ https://issues.apache.org/jira/browse/KAFKA-1305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1305: -- Status: Patch Available (was: Open) > Controller can hang on controlled shutdow

Re: including KAFKA-1555 in 0.8.2?

+1. On Thu, Oct 9, 2014 at 6:41 PM, Jun Rao wrote: > Hi, Everyone, > > I just committed KAFKA-1555 (min.isr support) to trunk. I felt that it's > probably useful to include it in the 0.8.2 release. Any objections? > > Thanks, > > Jun >

[jira] [Commented] (KAFKA-1305) Controller can hang on controlled shutdown with auto leader balance enabled

[ https://issues.apache.org/jira/browse/KAFKA-1305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167050#comment-14167050 ] Neha Narkhede commented on KAFKA-1305: -- [~junrao], [~sriharsha] What's the value in c

Re: Review Request 26560: Patch for KAFKA-1305

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26560/#review56156 --- core/src/main/scala/kafka/server/KafkaConfig.scala

[jira] [Comment Edited] (KAFKA-1697) remove code related to ack>1 on the broker

[ https://issues.apache.org/jira/browse/KAFKA-1697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14166144#comment-14166144 ] Neha Narkhede edited comment on KAFKA-1697 at 10/10/14 4:12 PM:

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167057#comment-14167057 ] Jay Kreps commented on KAFKA-1555: -- w00t! > provide strong consistency with reasonable a

Re: Review Request 26474: KAFKA-1654 Provide a way to override server configuration from command line

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26474/ --- (Updated Oct. 10, 2014, 4:23 p.m.) Review request for kafka and Neha Narkhede.

Re: including KAFKA-1555 in 0.8.2?

+1 On Oct 10, 2014 12:08 PM, "Neha Narkhede" wrote: > +1. > > On Thu, Oct 9, 2014 at 6:41 PM, Jun Rao wrote: > > > Hi, Everyone, > > > > I just committed KAFKA-1555 (min.isr support) to trunk. I felt that it's > > probably useful to include it in the 0.8.2 release. Any objections? > > > > Thank

Re: including KAFKA-1555 in 0.8.2?

+1 :) On Fri, Oct 10, 2014 at 9:34 AM, Joe Stein wrote: > +1 > On Oct 10, 2014 12:08 PM, "Neha Narkhede" wrote: > >> +1. >> >> On Thu, Oct 9, 2014 at 6:41 PM, Jun Rao wrote: >> >> > Hi, Everyone, >> > >> > I just committed KAFKA-1555 (min.isr support) to trunk. I felt that it's >> > probably u

Re: Security JIRAS

I'd vote for accepting every major change with the relevant system tests. We didn't do this for major features in the past that lead to weak coverage and a great deal of work for someone else to add tests for features that were done in the past. I'm guilty of this myself :-( On Thu, Oct 9, 2014 at

Re: including KAFKA-1555 in 0.8.2?

+1 On 10/10/14 9:39 AM, "Gwen Shapira" wrote: >+1 :) > >On Fri, Oct 10, 2014 at 9:34 AM, Joe Stein wrote: >> +1 >> On Oct 10, 2014 12:08 PM, "Neha Narkhede" >>wrote: >> >>> +1. >>> >>> On Thu, Oct 9, 2014 at 6:41 PM, Jun Rao wrote: >>> >>> > Hi, Everyone, >>> > >>> > I just committed KAFKA-1

Re: Security JIRAS

I would be strong +1 on that. I’ve seen a lot of regressions on other projects when new functionality cause regressions when running in secure mode. Jarcec On Oct 10, 2014, at 9:43 AM, Neha Narkhede wrote: > I'd vote for accepting every major change with the relevant system tests. > We didn't

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167113#comment-14167113 ] Sriram Subramanian commented on KAFKA-1555: --- Awesome. I suggest we document the

[jira] [Updated] (KAFKA-559) Garbage collect old consumer metadata entries

[ https://issues.apache.org/jira/browse/KAFKA-559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-559: Labels: newbie project (was: project) > Garbage collect old consumer metadata entries >

[jira] [Commented] (KAFKA-1305) Controller can hang on controlled shutdown with auto leader balance enabled

[ https://issues.apache.org/jira/browse/KAFKA-1305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167145#comment-14167145 ] Sriharsha Chintalapani commented on KAFKA-1305: --- [~nehanarkhede] [~junrao] m

Re: Review Request 26503: Patch for KAFKA-1493

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26503/#review56164 --- Thanks for the patch. A couple of high level questions. 1. Is the f

[jira] [Updated] (KAFKA-559) Garbage collect old consumer metadata entries

[ https://issues.apache.org/jira/browse/KAFKA-559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-559: Reviewer: Neha Narkhede > Garbage collect old consumer metadata entries > ---

[jira] [Commented] (KAFKA-1493) Use a well-documented LZ4 compression format and remove redundant LZ4HC option

[ https://issues.apache.org/jira/browse/KAFKA-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167153#comment-14167153 ] Jun Rao commented on KAFKA-1493: James, Could you help review the format in Ivan's patch?

Review Request 26563: Patch for KAFKA-1692

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

[jira] [Updated] (KAFKA-1692) [Java New Producer] IO Thread Name Must include Client ID

[ https://issues.apache.org/jira/browse/KAFKA-1692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1692: - Assignee: Ewen Cheslack-Postava (was: Jun Rao) Status: Patch Available (was

[jira] [Updated] (KAFKA-1692) [Java New Producer] IO Thread Name Must include Client ID

[ https://issues.apache.org/jira/browse/KAFKA-1692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1692: - Attachment: KAFKA-1692.patch > [Java New Producer] IO Thread Name Must include C

[jira] [Commented] (KAFKA-1692) [Java New Producer] IO Thread Name Must include Client ID

[ https://issues.apache.org/jira/browse/KAFKA-1692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167169#comment-14167169 ] Ewen Cheslack-Postava commented on KAFKA-1692: -- Created reviewboard https://r

Review Request 26564: Patch for KAFKA-1471

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

[jira] [Updated] (KAFKA-1471) Add Producer Unit Tests for LZ4 and LZ4HC compression

[ https://issues.apache.org/jira/browse/KAFKA-1471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1471: - Assignee: Ewen Cheslack-Postava Status: Patch Available (was: Open) > Add P

[jira] [Updated] (KAFKA-1471) Add Producer Unit Tests for LZ4 and LZ4HC compression

[ https://issues.apache.org/jira/browse/KAFKA-1471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1471: - Attachment: KAFKA-1471.patch > Add Producer Unit Tests for LZ4 and LZ4HC compressi

[jira] [Commented] (KAFKA-1305) Controller can hang on controlled shutdown with auto leader balance enabled

[ https://issues.apache.org/jira/browse/KAFKA-1305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167179#comment-14167179 ] Jun Rao commented on KAFKA-1305: Yes, in theory, we can make the queue unbounded. However,

[jira] [Commented] (KAFKA-1471) Add Producer Unit Tests for LZ4 and LZ4HC compression

[ https://issues.apache.org/jira/browse/KAFKA-1471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167178#comment-14167178 ] Ewen Cheslack-Postava commented on KAFKA-1471: -- Created reviewboard https://r

[jira] [Commented] (KAFKA-1471) Add Producer Unit Tests for LZ4 and LZ4HC compression

[ https://issues.apache.org/jira/browse/KAFKA-1471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167183#comment-14167183 ] Ewen Cheslack-Postava commented on KAFKA-1471: -- This updated version applies

[jira] [Commented] (KAFKA-1583) Kafka API Refactoring

[ https://issues.apache.org/jira/browse/KAFKA-1583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167184#comment-14167184 ] Jun Rao commented on KAFKA-1583: Guozhang, Now that the 0.8.2 branch is cut, do you want

[jira] [Commented] (KAFKA-1583) Kafka API Refactoring

[ https://issues.apache.org/jira/browse/KAFKA-1583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167187#comment-14167187 ] Guozhang Wang commented on KAFKA-1583: -- Sure, will do that asap. > Kafka API Refacto

[jira] [Reopened] (KAFKA-1670) Corrupt log files for segment.bytes values close to Int.MaxInt

[ https://issues.apache.org/jira/browse/KAFKA-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-1670: -- > Corrupt log files for segment.bytes values close to Int.MaxInt > -

[jira] [Commented] (KAFKA-1670) Corrupt log files for segment.bytes values close to Int.MaxInt

[ https://issues.apache.org/jira/browse/KAFKA-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167219#comment-14167219 ] Guozhang Wang commented on KAFKA-1670: -- Hi [~sriharsha] [~junrao] this patch causes s

[jira] [Commented] (KAFKA-1670) Corrupt log files for segment.bytes values close to Int.MaxInt

[ https://issues.apache.org/jira/browse/KAFKA-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167223#comment-14167223 ] Sriharsha Chintalapani commented on KAFKA-1670: --- [~guozhang] Sorry will fix

Review Request 26566: Patch for KAFKA-1680

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

[jira] [Updated] (KAFKA-1680) JmxTool exits if no arguments are given

[ https://issues.apache.org/jira/browse/KAFKA-1680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1680: - Attachment: KAFKA-1680.patch > JmxTool exits if no arguments are given > -

[jira] [Updated] (KAFKA-1680) JmxTool exits if no arguments are given

[ https://issues.apache.org/jira/browse/KAFKA-1680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1680: - Assignee: Ewen Cheslack-Postava Status: Patch Available (was: Open) > JmxTo

[jira] [Commented] (KAFKA-1680) JmxTool exits if no arguments are given

[ https://issues.apache.org/jira/browse/KAFKA-1680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167228#comment-14167228 ] Ewen Cheslack-Postava commented on KAFKA-1680: -- Created reviewboard https://r

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167261#comment-14167261 ] Gwen Shapira commented on KAFKA-1555: - will be happy to do that. Is the wiki the right

[jira] [Commented] (KAFKA-1670) Corrupt log files for segment.bytes values close to Int.MaxInt

[ https://issues.apache.org/jira/browse/KAFKA-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167422#comment-14167422 ] Guozhang Wang commented on KAFKA-1670: -- No worries :) Let me know if you need more in

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167464#comment-14167464 ] Sriram Subramanian commented on KAFKA-1555: --- My vote would be to update our docu

[jira] [Created] (KAFKA-1700) examples directory - README and shell scripts are out of date

Geoffrey Anderson created KAFKA-1700: Summary: examples directory - README and shell scripts are out of date Key: KAFKA-1700 URL: https://issues.apache.org/jira/browse/KAFKA-1700 Project: Kafka

Review Request 26575: Fix for KAFKA-1700

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

[jira] [Updated] (KAFKA-1700) examples directory - README and shell scripts are out of date

[ https://issues.apache.org/jira/browse/KAFKA-1700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Geoffrey Anderson updated KAFKA-1700: - Attachment: KAFKA-1700.patch > examples directory - README and shell scripts are out of da

[jira] [Commented] (KAFKA-1700) examples directory - README and shell scripts are out of date

[ https://issues.apache.org/jira/browse/KAFKA-1700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167501#comment-14167501 ] Geoffrey Anderson commented on KAFKA-1700: -- Created reviewboard https://reviews.a

[jira] [Created] (KAFKA-1701) Improve controller and broker message handling.

Jiangjie Qin created KAFKA-1701: --- Summary: Improve controller and broker message handling. Key: KAFKA-1701 URL: https://issues.apache.org/jira/browse/KAFKA-1701 Project: Kafka Issue Type: Impro

Re: including KAFKA-1555 in 0.8.2?

+1 On Fri, Oct 10, 2014 at 04:53:45PM +, Sriram Subramanian wrote: > +1 > > On 10/10/14 9:39 AM, "Gwen Shapira" wrote: > > >+1 :) > > > >On Fri, Oct 10, 2014 at 9:34 AM, Joe Stein wrote: > >> +1 > >> On Oct 10, 2014 12:08 PM, "Neha Narkhede" > >>wrote: > >> > >>> +1. > >>> > >>> On Thu,

[jira] [Assigned] (KAFKA-1634) Update protocol wiki to reflect the new offset management feature

[ https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy reassigned KAFKA-1634: - Assignee: Joel Koshy (was: Jun Rao) > Update protocol wiki to reflect the new offset management

[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=14167600#comment-14167600 ] Joel Koshy commented on KAFKA-1499: --- [~omkreddy] will review your other patch, but it se

[jira] [Commented] (KAFKA-1634) Update protocol wiki to reflect the new offset management feature

[ https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167696#comment-14167696 ] Joel Koshy commented on KAFKA-1634: --- Actually, one more potential source of confusion is

[jira] [Commented] (KAFKA-1634) Update protocol wiki to reflect the new offset management feature

[ https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167700#comment-14167700 ] Joel Koshy commented on KAFKA-1634: --- (BTW, I'm looking for a +1 or -1 on the above comm

[jira] [Updated] (KAFKA-1634) Improve semantics of timestamp in OffsetCommitRequests and update documentation

[ https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-1634: -- Summary: Improve semantics of timestamp in OffsetCommitRequests and update documentation (was: Improve

[jira] [Updated] (KAFKA-1634) Improve semantics of timestamp in OffsetCommitRequests

[ https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-1634: -- Summary: Improve semantics of timestamp in OffsetCommitRequests (was: Update protocol wiki to reflect t

[DISCUSSION] Message Metadata

Hello all, I put some thoughts on enhancing our current message metadata format to solve a bunch of existing issues: https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Enriched+Message+Metadata This wiki page is for kicking off some discussions about the feasibility of adding more info into

Re: [DISCUSSION] Message Metadata

Thanks Guozhang! This is an excellent write-up and the approach nicely consolidates a number of long-standing issues. It would be great if everyone can review this carefully and give feedback. Also, wrt discussion in the past we have used a mix of wiki comments and the mailing list. Personally, I