[jira] [Commented] (KAFKA-7837) maybeShrinkIsr may not reflect OfflinePartitions immediately

[ https://issues.apache.org/jira/browse/KAFKA-7837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750805#comment-16750805 ] Dhruvil Shah commented on KAFKA-7837: - [~junrao] [~lindong] having looked a bit into

[jira] [Comment Edited] (KAFKA-7837) maybeShrinkIsr may not reflect OfflinePartitions immediately

[ https://issues.apache.org/jira/browse/KAFKA-7837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750805#comment-16750805 ] Dhruvil Shah edited comment on KAFKA-7837 at 1/24/19 7:14 AM: -

[jira] [Commented] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0

[ https://issues.apache.org/jira/browse/KAFKA-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750785#comment-16750785 ] ASF GitHub Bot commented on KAFKA-7652: --- guozhangwang commented on pull request #61

[jira] [Commented] (KAFKA-6833) KafkaProducer throws "Invalid partition given with record" exception

[ https://issues.apache.org/jira/browse/KAFKA-6833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750634#comment-16750634 ] ASF GitHub Bot commented on KAFKA-6833: --- hachikuji commented on pull request #6154:

[jira] [Updated] (KAFKA-6833) KafkaProducer throws "Invalid partition given with record" exception

[ https://issues.apache.org/jira/browse/KAFKA-6833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6833: --- Fix Version/s: 2.0.2 > KafkaProducer throws "Invalid partition given with record" exception >

[jira] [Commented] (KAFKA-7440) Use leader epoch in consumer fetch requests

[ https://issues.apache.org/jira/browse/KAFKA-7440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750626#comment-16750626 ] ASF GitHub Bot commented on KAFKA-7440: --- mumrah commented on pull request #6190: KA

[jira] [Created] (KAFKA-7866) Duplicate offsets after transaction index append failure

Jason Gustafson created KAFKA-7866: -- Summary: Duplicate offsets after transaction index append failure Key: KAFKA-7866 URL: https://issues.apache.org/jira/browse/KAFKA-7866 Project: Kafka Is

[jira] [Updated] (KAFKA-7855) Kafka Streams Maven Archetype quickstart fails to compile out of the box

[ https://issues.apache.org/jira/browse/KAFKA-7855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7855: - Labels: newbie++ (was: ) > Kafka Streams Maven Archetype quickstart fails to compile out of the

[jira] [Updated] (KAFKA-7849) Warning when adding GlobalKTable

[ https://issues.apache.org/jira/browse/KAFKA-7849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7849: - Labels: newbie (was: ) > Warning when adding GlobalKTable > > >

[jira] [Created] (KAFKA-7865) Kafka Constant Consumer Errors for ~30 min after Network Blip

Aravind Velamur Srinivasan created KAFKA-7865: - Summary: Kafka Constant Consumer Errors for ~30 min after Network Blip Key: KAFKA-7865 URL: https://issues.apache.org/jira/browse/KAFKA-7865

[jira] [Resolved] (KAFKA-6995) Make config "internal.leave.group.on.close" public

[ https://issues.apache.org/jira/browse/KAFKA-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-6995. Resolution: Won't Fix We are planning to deprecate this config with the introduction of KIP-345. 

[jira] [Commented] (KAFKA-7740) Kafka Admin Client should be able to manage user/client configurations for users and clients

[ https://issues.apache.org/jira/browse/KAFKA-7740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750573#comment-16750573 ] ASF GitHub Bot commented on KAFKA-7740: --- yaodong66 commented on pull request #6189:

[jira] [Updated] (KAFKA-7740) Kafka Admin Client should be able to manage user/client configurations for users and clients

[ https://issues.apache.org/jira/browse/KAFKA-7740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yaodong Yang updated KAFKA-7740: Summary: Kafka Admin Client should be able to manage user/client configurations for users and clien

[jira] [Commented] (KAFKA-4850) RocksDb cannot use Bloom Filters

[ https://issues.apache.org/jira/browse/KAFKA-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750565#comment-16750565 ] ASF GitHub Bot commented on KAFKA-4850: --- guozhangwang commented on pull request #60

[jira] [Commented] (KAFKA-7782) cleanup policy for offsets topic should be configurable

[ https://issues.apache.org/jira/browse/KAFKA-7782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750538#comment-16750538 ] Guozhang Wang commented on KAFKA-7782: -- More specifically the "delete" logic is desc

[jira] [Assigned] (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 ] Yishun Guan reassigned KAFKA-6460: -- Assignee: Yishun Guan > Add mocks for state stores used in Streams unit testing >

[jira] [Assigned] (KAFKA-7864) AdminZkClient.validateTopicCreate() should validate that partitions are 0-based

[ https://issues.apache.org/jira/browse/KAFKA-7864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani reassigned KAFKA-7864: - Assignee: Ryan > AdminZkClient.validateTopicCreate() should validate tha

[jira] [Created] (KAFKA-7864) AdminZkClient.validateTopicCreate() should validate that partitions are 0-based

Jun Rao created KAFKA-7864: -- Summary: AdminZkClient.validateTopicCreate() should validate that partitions are 0-based Key: KAFKA-7864 URL: https://issues.apache.org/jira/browse/KAFKA-7864 Project: Kafka

[jira] [Commented] (KAFKA-7854) Behavior change in controller picking up partition reassignment tasks since 1.1.0

[ https://issues.apache.org/jira/browse/KAFKA-7854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750455#comment-16750455 ] Ismael Juma commented on KAFKA-7854: Would you be interested in helping move some of

[jira] [Updated] (KAFKA-7740) Kafka Admin Client should be able to manage quota configurations for users and clients

[ https://issues.apache.org/jira/browse/KAFKA-7740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yaodong Yang updated KAFKA-7740: Summary: Kafka Admin Client should be able to manage quota configurations for users and clients (w

[jira] [Commented] (KAFKA-7859) Replace LeaveGroup request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-7859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750347#comment-16750347 ] ASF GitHub Bot commented on KAFKA-7859: --- abbccdda commented on pull request #6188:

[jira] [Updated] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

[ https://issues.apache.org/jira/browse/KAFKA-5117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-5117: - Fix Version/s: 2.0.2 2.1.1 2.2.0 > Kafka Co

[jira] [Resolved] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

[ https://issues.apache.org/jira/browse/KAFKA-5117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-5117. -- Resolution: Fixed Assignee: Chris Egerton (was: Randall Hauch) Resolved with https://git

[jira] [Commented] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

[ https://issues.apache.org/jira/browse/KAFKA-5117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750334#comment-16750334 ] ASF GitHub Bot commented on KAFKA-5117: --- ewencp commented on pull request #6129: KA

[jira] [Created] (KAFKA-7863) Kafka 1.1.1 JmxReporter doesn't remove old mbean(OOME as result)

Alexandr Minaev created KAFKA-7863: -- Summary: Kafka 1.1.1 JmxReporter doesn't remove old mbean(OOME as result) Key: KAFKA-7863 URL: https://issues.apache.org/jira/browse/KAFKA-7863 Project: Kafka

[jira] [Updated] (KAFKA-7740) Kafka Admin Client should be able to manage configurations for users and clients

[ https://issues.apache.org/jira/browse/KAFKA-7740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yaodong Yang updated KAFKA-7740: Summary: Kafka Admin Client should be able to manage configurations for users and clients (was: Ka

[jira] [Created] (KAFKA-7862) Modify JoinGroup logic to incorporate group.instance.id change

Boyang Chen created KAFKA-7862: -- Summary: Modify JoinGroup logic to incorporate group.instance.id change Key: KAFKA-7862 URL: https://issues.apache.org/jira/browse/KAFKA-7862 Project: Kafka Iss

[jira] [Commented] (KAFKA-4968) The NetworkClient should rate-limit its log messages about protocol downgrades

[ https://issues.apache.org/jira/browse/KAFKA-4968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750286#comment-16750286 ] ASF GitHub Bot commented on KAFKA-4968: --- cmccabe commented on pull request #2754: K

[jira] [Comment Edited] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750278#comment-16750278 ] James Cheng edited comment on KAFKA-7657 at 1/23/19 5:59 PM: -

[jira] [Commented] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750278#comment-16750278 ] James Cheng commented on KAFKA-7657: This was fixed in [https://github.com/apache/kaf

[jira] [Commented] (KAFKA-7854) Behavior change in controller picking up partition reassignment tasks since 1.1.0

[ https://issues.apache.org/jira/browse/KAFKA-7854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750268#comment-16750268 ] Adem Efe Gencer commented on KAFKA-7854: [~ijuma], thanks for your response and s

[jira] [Commented] (KAFKA-5276) Support derived and prefixed configs in DescribeConfigs (KIP-133)

[ https://issues.apache.org/jira/browse/KAFKA-5276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750156#comment-16750156 ] Srinivas Reddy commented on KAFKA-5276: --- [~guozhang] [~ijuma], Should I pick this t

[jira] [Closed] (KAFKA-7852) Add public version of EmbeddedKafkaCluster

[ https://issues.apache.org/jira/browse/KAFKA-7852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler closed KAFKA-7852. --- > Add public version of EmbeddedKafkaCluster > -- > >

[jira] [Commented] (KAFKA-7852) Add public version of EmbeddedKafkaCluster

[ https://issues.apache.org/jira/browse/KAFKA-7852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750178#comment-16750178 ] John Roesler commented on KAFKA-7852: - Yes, it is. I searched our Jira, but I didn't

[jira] [Resolved] (KAFKA-7852) Add public version of EmbeddedKafkaCluster

[ https://issues.apache.org/jira/browse/KAFKA-7852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7852. - Resolution: Duplicate > Add public version of EmbeddedKafkaCluster >

[jira] [Commented] (KAFKA-5272) Improve validation for Alter Configs (KIP-133)

[ https://issues.apache.org/jira/browse/KAFKA-5272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750159#comment-16750159 ] Srinivas Reddy commented on KAFKA-5272: --- The [PR #3210| https://github.com/apache/k

[jira] [Assigned] (KAFKA-4680) min.insync.replicas can be set higher than replication factor

[ https://issues.apache.org/jira/browse/KAFKA-4680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Srinivas Reddy reassigned KAFKA-4680: - Assignee: Srinivas Reddy > min.insync.replicas can be set higher than replication factor

[jira] [Resolved] (KAFKA-5272) Improve validation for Alter Configs (KIP-133)

[ https://issues.apache.org/jira/browse/KAFKA-5272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Srinivas Reddy resolved KAFKA-5272. --- Resolution: Fixed > Improve validation for Alter Configs (KIP-133) >

[jira] [Commented] (KAFKA-7819) Trogdor - Improve RoundTripWorker

[ https://issues.apache.org/jira/browse/KAFKA-7819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750065#comment-16750065 ] ASF GitHub Bot commented on KAFKA-7819: --- stanislavkozlovski commented on pull reque

[jira] [Updated] (KAFKA-7794) kafka.tools.GetOffsetShell does not return the offset in some cases

[ https://issues.apache.org/jira/browse/KAFKA-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniele Ascione updated KAFKA-7794: --- Description: For some input for the timestamps (different from -1 or -2) the GetOffset is no

[jira] [Comment Edited] (KAFKA-7861) AlterConfig may change the source of another config entry if it matches the broker default

[ https://issues.apache.org/jira/browse/KAFKA-7861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750034#comment-16750034 ] Edoardo Comar edited comment on KAFKA-7861 at 1/23/19 2:22 PM:

[jira] [Updated] (KAFKA-7819) Trogdor - Improve RoundTripWorker

[ https://issues.apache.org/jira/browse/KAFKA-7819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7819: --- Description: Trogdor's RoundTripWorker task has a couple of shortcomings: * Consumer

[jira] [Commented] (KAFKA-7861) AlterConfig may change the source of another config entry if it matches the broker default

[ https://issues.apache.org/jira/browse/KAFKA-7861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750034#comment-16750034 ] Edoardo Comar commented on KAFKA-7861: -- Running the attached AlterConfigJira example

[jira] [Updated] (KAFKA-7861) AlterConfig may change the source of another config entry if it matches the broker default

[ https://issues.apache.org/jira/browse/KAFKA-7861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-7861: - Attachment: AlterConfigJira.java > AlterConfig may change the source of another config entry if i

[jira] [Created] (KAFKA-7861) AlterConfig may change the source of another config entry if it matches the broker default

Edoardo Comar created KAFKA-7861: Summary: AlterConfig may change the source of another config entry if it matches the broker default Key: KAFKA-7861 URL: https://issues.apache.org/jira/browse/KAFKA-7861

[jira] [Commented] (KAFKA-7851) Continue data streaming while rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-7851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16749834#comment-16749834 ] Christian Richter commented on KAFKA-7851: -- Thank you [~enether]! Seeing KAFKA-5

[jira] [Commented] (KAFKA-7854) Behavior change in controller picking up partition reassignment tasks since 1.1.0

[ https://issues.apache.org/jira/browse/KAFKA-7854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16749813#comment-16749813 ] Ismael Juma commented on KAFKA-7854: https://cwiki.apache.org/confluence/display/KAFK

[jira] [Comment Edited] (KAFKA-7854) Behavior change in controller picking up partition reassignment tasks since 1.1.0

[ https://issues.apache.org/jira/browse/KAFKA-7854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16749813#comment-16749813 ] Ismael Juma edited comment on KAFKA-7854 at 1/23/19 11:04 AM: -

[jira] [Commented] (KAFKA-7854) Behavior change in controller picking up partition reassignment tasks since 1.1.0

[ https://issues.apache.org/jira/browse/KAFKA-7854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16749810#comment-16749810 ] Ismael Juma commented on KAFKA-7854: There is already a KIP for doing reassignment an

[jira] [Commented] (KAFKA-7851) Continue data streaming while rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-7851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16749793#comment-16749793 ] Stanislav Kozlovski commented on KAFKA-7851: [~cri] it's also worth mentionin

[jira] [Assigned] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-2939: -- Assignee: (was: Mariam John) > Make AbstractConfig.logUnused() tunable for clients > -

[jira] [Assigned] (KAFKA-2111) Command Line Standardization - Add Help Arguments & List Required Fields

[ https://issues.apache.org/jira/browse/KAFKA-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-2111: -- Assignee: (was: Mariam John) > Command Line Standardization - Add Help Arguments & List Re

[jira] [Assigned] (KAFKA-6708) Review Exception messages with regards to Serde Useage

[ https://issues.apache.org/jira/browse/KAFKA-6708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-6708: -- Assignee: (was: Mariam John) > Review Exception messages with regards to Serde Useage > --

[jira] [Assigned] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-4650: -- Assignee: (was: Mariam John) > Improve test coverage org.apache.kafka.streams.kstream.inte

[jira] [Assigned] (KAFKA-7492) Explain `null` handling for reduce and aggregate

[ https://issues.apache.org/jira/browse/KAFKA-7492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-7492: -- Assignee: (was: Mariam John) > Explain `null` handling for reduce and aggregate >

[jira] [Created] (KAFKA-7860) kafka broker restart isr lose

qinzl_1 created KAFKA-7860: -- Summary: kafka broker restart isr lose Key: KAFKA-7860 URL: https://issues.apache.org/jira/browse/KAFKA-7860 Project: Kafka Issue Type: Bug Reporter: qinzl_1