[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&focusedCommentId=16420165#comment-16420165 ] Guozhang Wang commented on KAFKA-6592: -- Yes, the KIP is only for proposing the change

[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&focusedCommentId=16420158#comment-16420158 ] ASF GitHub Bot commented on KAFKA-6630: --- junrao closed pull request #4668: KAFKA-663

[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&focusedCommentId=16420029#comment-16420029 ] huxihx commented on KAFKA-6592: --- [~guozhang] [KIP-265|https://cwiki.apache.org/confluence/d

[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&focusedCommentId=16419922#comment-16419922 ] ASF GitHub Bot commented on KAFKA-6707: --- guozhangwang closed pull request #4762: [KA

[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&focusedCommentId=16419906#comment-16419906 ] ASF GitHub Bot commented on KAFKA-6702: --- guozhangwang closed pull request #4772: [KA

[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&focusedCommentId=16419769#comment-16419769 ] Guozhang Wang commented on KAFKA-6395: -- I'm going to merging this ticket to KAFKA-563

[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 that

[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 that

[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&focusedCommentId=16419740#comment-16419740 ] Chris Egerton commented on KAFKA-6417: -- [~cotedm] I _think_ that the behavior for sev

[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&focusedCommentId=16419622#comment-16419622 ] Randall Hauch commented on KAFKA-6417: -- [~ChrisEgerton], have we also thought about l

[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&focusedCommentId=16419613#comment-16419613 ] Dustin Cote commented on KAFKA-6417: This makes sense, basically if you have a top lev

[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&focusedCommentId=16419456#comment-16419456 ] Guozhang Wang commented on KAFKA-6474: -- Definitely :) That will let reviewers to prov

[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 introd

[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 con

[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&focusedCommentId=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&focusedCommentId=16419345#comment-16419345 ] Narayan Periwal commented on KAFKA-6681: [~yuzhih...@gmail.com], We had one more o

[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&focusedCommentId=16419334#comment-16419334 ] Chris Egerton commented on KAFKA-6417: -- [~cotedm] after discussing this with [~kkonst

[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&focusedCommentId=16419331#comment-16419331 ] Matt Farmer commented on KAFKA-6725: I've got some code locally on this that I'm plann

[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&focusedCommentId=16419175#comment-16419175 ] Filipe Agapito commented on KAFKA-6474: --- Hi John. I hope you are also doing well. Th

[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&focusedCommentId=16419047#comment-16419047 ] ASF GitHub Bot commented on KAFKA-6727: --- big-andy-coates opened a new pull request #

[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&focusedCommentId=16419042#comment-16419042 ] ASF GitHub Bot commented on KAFKA-6726: --- edoardocomar opened a new pull request #479

[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 Cre

[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: Kafka

[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: Impro