[jira] [Commented] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420165#comment-16420165 ] Guozhang Wang commented on KAFKA-6592: -- Yes, the KIP is only for proposing the changes, after the

[jira] [Commented] (KAFKA-6630) Speed up the processing of TopicDeletionStopReplicaResponseReceived events on the controller

[ https://issues.apache.org/jira/browse/KAFKA-6630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420158#comment-16420158 ] ASF GitHub Bot commented on KAFKA-6630: --- junrao closed pull request #4668: KAFKA-6630: Speed up the

[jira] [Commented] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420029#comment-16420029 ] huxihx commented on KAFKA-6592: --- [~guozhang]

[jira] [Commented] (KAFKA-6707) The default value for config of Type.LONG should be *L

[ https://issues.apache.org/jira/browse/KAFKA-6707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419922#comment-16419922 ] ASF GitHub Bot commented on KAFKA-6707: --- guozhangwang closed pull request #4762: [KAFKA-6707]The

[jira] [Commented] (KAFKA-6702) Wrong className in LoggerFactory.getLogger method

[ https://issues.apache.org/jira/browse/KAFKA-6702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419906#comment-16419906 ] ASF GitHub Bot commented on KAFKA-6702: --- guozhangwang closed pull request #4772: [KAFKA-6702]Wrong

[jira] [Resolved] (KAFKA-6612) Added logic to prevent increasing partition counts during topic deletion

[ https://issues.apache.org/jira/browse/KAFKA-6612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Wang resolved KAFKA-6612. --- Resolution: Fixed > Added logic to prevent increasing partition counts during topic deletion >

[jira] [Commented] (KAFKA-6395) KIP: Add Record Header support to Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419769#comment-16419769 ] Guozhang Wang commented on KAFKA-6395: -- I'm going to merging this ticket to KAFKA-5632 and re-link

[jira] [Resolved] (KAFKA-6395) KIP: Add Record Header support to Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6395. -- Resolution: Duplicate > KIP: Add Record Header support to Kafka Streams >

[jira] [Updated] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6460: - Description: We'd like to use mocks for different types of state stores: kv, window, session

[jira] [Commented] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException

[ https://issues.apache.org/jira/browse/KAFKA-6417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419740#comment-16419740 ] Chris Egerton commented on KAFKA-6417: -- [~cotedm] I _think_ that the behavior for several uber-JAR'd

[jira] [Commented] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException

[ https://issues.apache.org/jira/browse/KAFKA-6417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419622#comment-16419622 ] Randall Hauch commented on KAFKA-6417: -- [~ChrisEgerton], have we also thought about logging messages

[jira] [Commented] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException

[ https://issues.apache.org/jira/browse/KAFKA-6417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419613#comment-16419613 ] Dustin Cote commented on KAFKA-6417: This makes sense, basically if you have a top level jar then you

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419456#comment-16419456 ] Guozhang Wang commented on KAFKA-6474: -- Definitely :) That will let reviewers to provide some early

[jira] [Updated] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Narayan Periwal updated KAFKA-6681: --- Description: We have seen this issue with the Kafka consumer, the new library that got

[jira] [Updated] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Narayan Periwal updated KAFKA-6681: --- Component/s: clients > Two instances of kafka consumer reading the same partition within a

[jira] [Comment Edited] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419345#comment-16419345 ] Narayan Periwal edited comment on KAFKA-6681 at 3/29/18 4:53 PM: -

[jira] [Commented] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419345#comment-16419345 ] Narayan Periwal commented on KAFKA-6681: [~yuzhih...@gmail.com], We had one more occurence of the

[jira] [Commented] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException

[ https://issues.apache.org/jira/browse/KAFKA-6417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419334#comment-16419334 ] Chris Egerton commented on KAFKA-6417: -- [~cotedm] after discussing this with [~kkonstantine] we think

[jira] [Commented] (KAFKA-6725) Indicate "isClosing" in the SinkTaskContext

[ https://issues.apache.org/jira/browse/KAFKA-6725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419331#comment-16419331 ] Matt Farmer commented on KAFKA-6725: I've got some code locally on this that I'm planning on

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419175#comment-16419175 ] Filipe Agapito commented on KAFKA-6474: --- Hi John. I hope you are also doing well. Thanks for the

[jira] [Commented] (KAFKA-6727) org.apache.kafka.clients.admin.Config has broken equals and hashCode method.

[ https://issues.apache.org/jira/browse/KAFKA-6727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419047#comment-16419047 ] ASF GitHub Bot commented on KAFKA-6727: --- big-andy-coates opened a new pull request #4796: KAFKA-6727

[jira] [Commented] (KAFKA-6726) KIP-277 - Fine Grained ACL for CreateTopics API

[ https://issues.apache.org/jira/browse/KAFKA-6726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419042#comment-16419042 ] ASF GitHub Bot commented on KAFKA-6726: --- edoardocomar opened a new pull request #4795: KAFKA-6726:

[jira] [Updated] (KAFKA-6726) KIP-277 - Fine Grained ACL for CreateTopics API

[ https://issues.apache.org/jira/browse/KAFKA-6726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-6726: - Summary: KIP-277 - Fine Grained ACL for CreateTopics API (was: KIP-277 - Fine Grained ACL for

[jira] [Created] (KAFKA-6727) org.apache.kafka.clients.admin.Config has broken equals and hashCode method.

Andy Coates created KAFKA-6727: -- Summary: org.apache.kafka.clients.admin.Config has broken equals and hashCode method. Key: KAFKA-6727 URL: https://issues.apache.org/jira/browse/KAFKA-6727 Project:

[jira] [Created] (KAFKA-6726) KIP-277 - Fine Grained ACL for CreateTopics A

Edoardo Comar created KAFKA-6726: Summary: KIP-277 - Fine Grained ACL for CreateTopics A Key: KAFKA-6726 URL: https://issues.apache.org/jira/browse/KAFKA-6726 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-5253) TopologyTestDriver must handle streams created with patterns

[ https://issues.apache.org/jira/browse/KAFKA-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16418503#comment-16418503 ] ASF GitHub Bot commented on KAFKA-5253: --- jadireddi opened a new pull request #4793: KAFKA-5253: