[jira] [Commented] (KAFKA-9092) Kafka Streams Upgrade Magic v0 does not support record headers

2019-10-24 Thread wxmimperio (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16958599#comment-16958599 ] wxmimperio commented on KAFKA-9092: --- [~mjsax] Hi, I think my cluster message format is

[jira] [Comment Edited] (KAFKA-9092) Kafka Streams Upgrade Magic v0 does not support record headers

2019-10-24 Thread wxmimperio (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16958599#comment-16958599 ] wxmimperio edited comment on KAFKA-9092 at 10/24/19 7:01 AM: -

[jira] [Updated] (KAFKA-9083) Various parsing issues in Values class

2019-10-24 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-9083: - Description: There are a number of small issues with the Connect framework's {{Values}} class th

[jira] [Created] (KAFKA-9093) NullPointerException in KafkaConsumer with group.instance.id

2019-10-24 Thread Rolef Heinrich (Jira)
Rolef Heinrich created KAFKA-9093: - Summary: NullPointerException in KafkaConsumer with group.instance.id Key: KAFKA-9093 URL: https://issues.apache.org/jira/browse/KAFKA-9093 Project: Kafka

[jira] [Assigned] (KAFKA-9093) NullPointerException in KafkaConsumer with group.instance.id

2019-10-24 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-9093: - Assignee: huxihx > NullPointerException in KafkaConsumer with group.instance.id > --

[jira] [Commented] (KAFKA-9093) NullPointerException in KafkaConsumer with group.instance.id

2019-10-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16958721#comment-16958721 ] ASF GitHub Bot commented on KAFKA-9093: --- huxihx commented on pull request #7590: KA

[jira] [Created] (KAFKA-9094) Validate the replicas for partition reassignments triggered through the /admin/reassign_partitions zNode

2019-10-24 Thread Stanislav Kozlovski (Jira)
Stanislav Kozlovski created KAFKA-9094: -- Summary: Validate the replicas for partition reassignments triggered through the /admin/reassign_partitions zNode Key: KAFKA-9094 URL: https://issues.apache.org/jira/b

[jira] [Commented] (KAFKA-9094) Validate the replicas for partition reassignments triggered through the /admin/reassign_partitions zNode

2019-10-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16958784#comment-16958784 ] ASF GitHub Bot commented on KAFKA-9094: --- stanislavkozlovski commented on pull reque

[jira] [Created] (KAFKA-9095) Kafka Cluster Issue when API Version =1

2019-10-24 Thread Mantesh Janagond (Jira)
Mantesh Janagond created KAFKA-9095: --- Summary: Kafka Cluster Issue when API Version =1 Key: KAFKA-9095 URL: https://issues.apache.org/jira/browse/KAFKA-9095 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-7181) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters IllegalStateException

2019-10-24 Thread amuthan Ganeshan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16958940#comment-16958940 ] amuthan Ganeshan commented on KAFKA-7181: - Thank you [~mjsax] for responding, is

[jira] [Commented] (KAFKA-9092) Kafka Streams Upgrade Magic v0 does not support record headers

2019-10-24 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16958952#comment-16958952 ] Guozhang Wang commented on KAFKA-9092: -- [~wxmimperio] I think you are hitting KAFKA-

[jira] [Created] (KAFKA-9096) Validate config inter-dependencies for KafkaConfig only after dynamic configs are loaded

2019-10-24 Thread Rajini Sivaram (Jira)
Rajini Sivaram created KAFKA-9096: - Summary: Validate config inter-dependencies for KafkaConfig only after dynamic configs are loaded Key: KAFKA-9096 URL: https://issues.apache.org/jira/browse/KAFKA-9096

[jira] [Commented] (KAFKA-5561) Java based TopicCommand to use the Admin client

2019-10-24 Thread Gokul Ramanan Subramanian (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16958985#comment-16958985 ] Gokul Ramanan Subramanian commented on KAFKA-5561: -- [~ppatierno] are you

[jira] [Commented] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient

2019-10-24 Thread Gokul Ramanan Subramanian (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16958988#comment-16958988 ] Gokul Ramanan Subramanian commented on KAFKA-5722: -- [~viktorsomogyi] are

[jira] [Commented] (KAFKA-5601) Refactor ReassignPartitionsCommand to use AdminClient

2019-10-24 Thread Gokul Ramanan Subramanian (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16958991#comment-16958991 ] Gokul Ramanan Subramanian commented on KAFKA-5601: -- [~tombentley] are yo

[jira] [Updated] (KAFKA-9093) NullPointerException in KafkaConsumer with group.instance.id

2019-10-24 Thread David Arthur (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-9093: Fix Version/s: (was: 2.3.1) 2.3.2 > NullPointerException in KafkaConsumer wi

[jira] [Commented] (KAFKA-7181) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters IllegalStateException

2019-10-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959150#comment-16959150 ] Matthias J. Sax commented on KAFKA-7181: As you can see on the ticket, it's not a

[jira] [Commented] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

2019-10-24 Thread Dallas Wrege (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959169#comment-16959169 ] Dallas Wrege commented on KAFKA-4969: - Bump. I would love to see this issue back in c

[jira] [Commented] (KAFKA-9083) Various parsing issues in Values class

2019-10-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959174#comment-16959174 ] ASF GitHub Bot commented on KAFKA-9083: --- C0urante commented on pull request #7593:

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

2019-10-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959188#comment-16959188 ] ASF GitHub Bot commented on KAFKA-9088: --- pierDipi commented on pull request #7594:

[jira] [Created] (KAFKA-9097) URL needs update - use https://kafka.apache.org/quickstart

2019-10-24 Thread Bernard A. Badger (Jira)
Bernard A. Badger created KAFKA-9097: Summary: URL needs update - use https://kafka.apache.org/quickstart Key: KAFKA-9097 URL: https://issues.apache.org/jira/browse/KAFKA-9097 Project: Kafka

[jira] [Created] (KAFKA-9098) Name Repartition Filter, Source, and Sink Processors

2019-10-24 Thread Bill Bejeck (Jira)
Bill Bejeck created KAFKA-9098: -- Summary: Name Repartition Filter, Source, and Sink Processors Key: KAFKA-9098 URL: https://issues.apache.org/jira/browse/KAFKA-9098 Project: Kafka Issue Type: Bu

[jira] [Commented] (KAFKA-6453) Reconsider timestamp propagation semantics

2019-10-24 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959244#comment-16959244 ] Boyang Chen commented on KAFKA-6453: Need to have both state store section and DSL se

[jira] [Commented] (KAFKA-6453) Reconsider timestamp propagation semantics

2019-10-24 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959246#comment-16959246 ] Boyang Chen commented on KAFKA-6453: Executor needs to first check in change into the

[jira] [Created] (KAFKA-9099) Reassignments should be retried after unexpected errors

2019-10-24 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9099: -- Summary: Reassignments should be retried after unexpected errors Key: KAFKA-9099 URL: https://issues.apache.org/jira/browse/KAFKA-9099 Project: Kafka Iss

[jira] [Commented] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

2019-10-24 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959306#comment-16959306 ] Sophie Blee-Goldman commented on KAFKA-4969: Bill's proposal has already been

[jira] [Commented] (KAFKA-8522) Tombstones can survive forever

2019-10-24 Thread Richard Yu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959308#comment-16959308 ] Richard Yu commented on KAFKA-8522: --- Found where the tombstones are inserted. That real

[jira] [Created] (KAFKA-9100) The controller code allows for replicas to get added to the assignment when the replicas goes online

2019-10-24 Thread Jose Armando Garcia Sancio (Jira)
Jose Armando Garcia Sancio created KAFKA-9100: - Summary: The controller code allows for replicas to get added to the assignment when the replicas goes online Key: KAFKA-9100 URL: https://issues.apache.

[jira] [Assigned] (KAFKA-9101) Create a fetch.max.bytes configuration for the broker

2019-10-24 Thread Colin McCabe (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe reassigned KAFKA-9101: --- Assignee: Colin McCabe > Create a fetch.max.bytes configuration for the broker > ---

[jira] [Created] (KAFKA-9101) Create a fetch.max.bytes configuration for the broker

2019-10-24 Thread Colin McCabe (Jira)
Colin McCabe created KAFKA-9101: --- Summary: Create a fetch.max.bytes configuration for the broker Key: KAFKA-9101 URL: https://issues.apache.org/jira/browse/KAFKA-9101 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-9102) Increase default zk session timeout and max lag

2019-10-24 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9102: -- Summary: Increase default zk session timeout and max lag Key: KAFKA-9102 URL: https://issues.apache.org/jira/browse/KAFKA-9102 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-9102) Increase default zk session timeout and max lag

2019-10-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959346#comment-16959346 ] ASF GitHub Bot commented on KAFKA-9102: --- hachikuji commented on pull request #7596:

[jira] [Commented] (KAFKA-9089) Reassignment should be resilient to unexpected errors

2019-10-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959373#comment-16959373 ] ASF GitHub Bot commented on KAFKA-9089: --- hachikuji commented on pull request #7562:

[jira] [Resolved] (KAFKA-9089) Reassignment should be resilient to unexpected errors

2019-10-24 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9089. Resolution: Fixed > Reassignment should be resilient to unexpected errors > ---

[jira] [Commented] (KAFKA-8729) Augment ProduceResponse error messaging for specific culprit records

2019-10-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959376#comment-16959376 ] ASF GitHub Bot commented on KAFKA-8729: --- guozhangwang commented on pull request #75

[jira] [Created] (KAFKA-9103) KIP-441: Add TaskLags to SubscriptionInfo

2019-10-24 Thread John Roesler (Jira)
John Roesler created KAFKA-9103: --- Summary: KIP-441: Add TaskLags to SubscriptionInfo Key: KAFKA-9103 URL: https://issues.apache.org/jira/browse/KAFKA-9103 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-8972) KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback state

2019-10-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959417#comment-16959417 ] ASF GitHub Bot commented on KAFKA-8972: --- guozhangwang commented on pull request #75

[jira] [Updated] (KAFKA-9098) Name Repartition Filter, Source, and Sink Processors

2019-10-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9098: --- Issue Type: Improvement (was: Bug) > Name Repartition Filter, Source, and Sink Processors >

[jira] [Commented] (KAFKA-4609) KTable/KTable join followed by groupBy and aggregate/count can result in duplicated results

2019-10-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959455#comment-16959455 ] Matthias J. Sax commented on KAFKA-4609: As you can see, the ticket is open. It w

[jira] [Commented] (KAFKA-9038) Allow creating partitions while partition reassignment is in progress

2019-10-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959473#comment-16959473 ] ASF GitHub Bot commented on KAFKA-9038: --- hachikuji commented on pull request #7582:

[jira] [Resolved] (KAFKA-9038) Allow creating partitions while partition reassignment is in progress

2019-10-24 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9038. Fix Version/s: 2.4.0 Resolution: Fixed > Allow creating partitions while partition r