[jira] [Comment Edited] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1

[ https://issues.apache.org/jira/browse/KAFKA-6054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939878#comment-16939878 ] Vasiliy edited comment on KAFKA-6054 at 9/28/19 6:54 AM: - Hi all,

[jira] [Comment Edited] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1

[ https://issues.apache.org/jira/browse/KAFKA-6054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939878#comment-16939878 ] Vasiliy edited comment on KAFKA-6054 at 9/28/19 6:32 AM: - Hi all,

[jira] [Commented] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1

[ https://issues.apache.org/jira/browse/KAFKA-6054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939878#comment-16939878 ] Vasiliy commented on KAFKA-6054: Hi all, we got error *Kafka Streams error “TaskAssignme

[jira] [Comment Edited] (KAFKA-8649) Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0

[ https://issues.apache.org/jira/browse/KAFKA-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939861#comment-16939861 ] Sophie Blee-Goldman edited comment on KAFKA-8649 at 9/28/19 6:07 AM: --

[jira] [Commented] (KAFKA-8649) Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0

[ https://issues.apache.org/jira/browse/KAFKA-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939861#comment-16939861 ] Sophie Blee-Goldman commented on KAFKA-8649: [~ferbncode] [~guozhang] [~mjsax

[jira] [Commented] (KAFKA-8700) Flaky Test QueryableStateIntegrationTest#queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939833#comment-16939833 ] xujianhai commented on KAFKA-8700: -- if this is a problem , maybe I can try to fix > Fla

[jira] [Commented] (KAFKA-8059) Flaky Test DynamicConnectionQuotaTest #testDynamicConnectionQuota

[ https://issues.apache.org/jira/browse/KAFKA-8059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939832#comment-16939832 ] xujianhai commented on KAFKA-8059: -- maybe I can try to repair this problem > Flaky Test

[jira] [Created] (KAFKA-8958) Fix Kafka Streams JavaDocs with regard to used Serdes

Matthias J. Sax created KAFKA-8958: -- Summary: Fix Kafka Streams JavaDocs with regard to used Serdes Key: KAFKA-8958 URL: https://issues.apache.org/jira/browse/KAFKA-8958 Project: Kafka Issue

[jira] [Commented] (KAFKA-7052) ExtractField SMT throws NPE - needs clearer error message

[ https://issues.apache.org/jira/browse/KAFKA-7052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939744#comment-16939744 ] Gunnar Morling commented on KAFKA-7052: --- Looking into this, and it's an interesting

[jira] [Commented] (KAFKA-7263) Container exception java.lang.IllegalStateException: Coordinator selected invalid assignment protocol: null

[ https://issues.apache.org/jira/browse/KAFKA-7263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939738#comment-16939738 ] Larry Li commented on KAFKA-7263: - We are experiencing exactly the same exception polling

[jira] [Updated] (KAFKA-8523) InsertField transformation fails when encountering tombstone event

[ https://issues.apache.org/jira/browse/KAFKA-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gunnar Morling updated KAFKA-8523: -- Description: When applying the {{InsertField}} transformation to a tombstone event, an excepti

[jira] [Updated] (KAFKA-8523) InsertField transformation fails when encountering tombstone event

[ https://issues.apache.org/jira/browse/KAFKA-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gunnar Morling updated KAFKA-8523: -- Description: When applying the {{InsertField}} transformation to a tombstone event, an excepti

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939732#comment-16939732 ] ASF GitHub Bot commented on KAFKA-7895: --- mjsax commented on pull request #7373: KAF

[jira] [Commented] (KAFKA-8523) InsertField transformation fails when encountering tombstone event

[ https://issues.apache.org/jira/browse/KAFKA-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939730#comment-16939730 ] Gunnar Morling commented on KAFKA-8523: --- Hey [~rhauch], [~frederic.tardif], yes, we

[jira] [Commented] (KAFKA-8934) Introduce Instance-level Metrics

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

[jira] [Resolved] (KAFKA-8427) Error while cleanup under windows for EmbeddedKafkaCluster

[ https://issues.apache.org/jira/browse/KAFKA-8427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8427. -- Fix Version/s: 2.4.0 Assignee: Guozhang Wang Resolution: Fixed Should have been

[jira] [Updated] (KAFKA-7990) Flaky Test KafkaStreamsTest#shouldCleanupOldStateDirs

[ https://issues.apache.org/jira/browse/KAFKA-7990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7990: - Fix Version/s: (was: 2.2.1) (was: 2.3.0) 2.4.0 > Fl

[jira] [Commented] (KAFKA-7990) Flaky Test KafkaStreamsTest#shouldCleanupOldStateDirs

[ https://issues.apache.org/jira/browse/KAFKA-7990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939698#comment-16939698 ] Guozhang Wang commented on KAFKA-7990: -- Should have been fixed via https://github.co

[jira] [Commented] (KAFKA-7921) Instable KafkaStreamsTest

[ https://issues.apache.org/jira/browse/KAFKA-7921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939697#comment-16939697 ] Guozhang Wang commented on KAFKA-7921: -- Should have been fixed via https://github.co

[jira] [Commented] (KAFKA-6215) KafkaStreamsTest fails in trunk

[ https://issues.apache.org/jira/browse/KAFKA-6215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939696#comment-16939696 ] Guozhang Wang commented on KAFKA-6215: -- Should have been fixed via https://github.co

[jira] [Updated] (KAFKA-7921) Instable KafkaStreamsTest

[ https://issues.apache.org/jira/browse/KAFKA-7921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7921: - Fix Version/s: (was: 2.3.0) 2.4.0 > Instable KafkaStreamsTest > --

[jira] [Resolved] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory

[ https://issues.apache.org/jira/browse/KAFKA-8319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8319. -- Fix Version/s: 2.4.0 Assignee: Guozhang Wang (was: Bill Bejeck) Resolution: Fix

[jira] [Commented] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory

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

[jira] [Updated] (KAFKA-8957) Improve docs about `min.isr` and `acks=all`

[ https://issues.apache.org/jira/browse/KAFKA-8957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8957: --- Summary: Improve docs about `min.isr` and `acks=all` (was: Improve docs about `min.isr.` and

[jira] [Created] (KAFKA-8957) Improve docs about `min.isr.` and `acks=all`

Matthias J. Sax created KAFKA-8957: -- Summary: Improve docs about `min.isr.` and `acks=all` Key: KAFKA-8957 URL: https://issues.apache.org/jira/browse/KAFKA-8957 Project: Kafka Issue Type: Im

[jira] [Commented] (KAFKA-6883) KafkaShortnamer should allow to convert Kerberos principal name to upper case user name

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

[jira] [Resolved] (KAFKA-6883) KafkaShortnamer should allow to convert Kerberos principal name to upper case user name

[ https://issues.apache.org/jira/browse/KAFKA-6883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6883. -- Fix Version/s: 2.4.0 Resolution: Fixed Issue resolved by pull request 7375 [https://github.com/a

[jira] [Created] (KAFKA-8956) Refactor DelayedCreatePartitions#updateWaiting to avoid modifying collection in foreach

Colin McCabe created KAFKA-8956: --- Summary: Refactor DelayedCreatePartitions#updateWaiting to avoid modifying collection in foreach Key: KAFKA-8956 URL: https://issues.apache.org/jira/browse/KAFKA-8956 P

[jira] [Created] (KAFKA-8955) Add an AbstractResponse#errorCounts method that takes a stream or iterable

Colin McCabe created KAFKA-8955: --- Summary: Add an AbstractResponse#errorCounts method that takes a stream or iterable Key: KAFKA-8955 URL: https://issues.apache.org/jira/browse/KAFKA-8955 Project: Kafka

[jira] [Commented] (KAFKA-8953) Consider renaming `UsePreviousTimeOnInvalidTimestamp` timestamp extractor

[ https://issues.apache.org/jira/browse/KAFKA-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939601#comment-16939601 ] Matthias J. Sax commented on KAFKA-8953: Thanks for you interest! I added you to

[jira] [Comment Edited] (KAFKA-8950) KafkaConsumer stops fetching

[ https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939538#comment-16939538 ] Will James edited comment on KAFKA-8950 at 9/27/19 3:24 PM: H

[jira] [Commented] (KAFKA-8950) KafkaConsumer stops fetching

[ https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939538#comment-16939538 ] Will James commented on KAFKA-8950: --- Here are relevant logs from before one occurance o

[jira] [Commented] (KAFKA-8954) Topic existence check is wrongly implemented in the DeleteOffset API

[ https://issues.apache.org/jira/browse/KAFKA-8954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939495#comment-16939495 ] ASF GitHub Bot commented on KAFKA-8954: --- dajac commented on pull request #7406: KAF

[jira] [Commented] (KAFKA-8907) Return topic configs in CreateTopics response

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

[jira] [Commented] (KAFKA-8887) Use purgatory for CreateAcls and DeleteAcls if implementation is async

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

[jira] [Assigned] (KAFKA-8954) Topic existence check is wrongly implemented in the DeleteOffset API

[ https://issues.apache.org/jira/browse/KAFKA-8954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot reassigned KAFKA-8954: -- Assignee: David Jacot > Topic existence check is wrongly implemented in the DeleteOffset API >

[jira] [Created] (KAFKA-8954) Topic existence check is wrongly implemented in the DeleteOffset API

David Jacot created KAFKA-8954: -- Summary: Topic existence check is wrongly implemented in the DeleteOffset API Key: KAFKA-8954 URL: https://issues.apache.org/jira/browse/KAFKA-8954 Project: Kafka

[jira] [Commented] (KAFKA-8953) Consider renaming `UsePreviousTimeOnInvalidTimestamp` timestamp extractor

[ https://issues.apache.org/jira/browse/KAFKA-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939179#comment-16939179 ] Rabi Kumar K C commented on KAFKA-8953: --- Hi [~mjsax] I am new to Kafka. Is it okay

[jira] [Created] (KAFKA-8953) Consider renaming `UsePreviousTimeOnInvalidTimestamp` timestamp extractor

Matthias J. Sax created KAFKA-8953: -- Summary: Consider renaming `UsePreviousTimeOnInvalidTimestamp` timestamp extractor Key: KAFKA-8953 URL: https://issues.apache.org/jira/browse/KAFKA-8953 Project:

[jira] [Commented] (KAFKA-7772) Dynamically adjust log level in Connect workers

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