[jira] [Commented] (KAFKA-8705) NullPointerException was thrown by topology optimization when two MergeNodes have common KeyChaingingNode

[ https://issues.apache.org/jira/browse/KAFKA-8705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892339#comment-16892339 ] Hiroshi Nakahara commented on KAFKA-8705: - [~bbejeck] Thank you for working on it quickly!  I'm

[jira] [Commented] (KAFKA-8078) Flaky Test TableTableJoinIntegrationTest#testInnerInner

[ https://issues.apache.org/jira/browse/KAFKA-8078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892326#comment-16892326 ] Boyang Chen commented on KAFKA-8078:

[jira] [Commented] (KAFKA-7937) Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup

[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892325#comment-16892325 ] Boyang Chen commented on KAFKA-7937:

[jira] [Commented] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-8179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892297#comment-16892297 ] ASF GitHub Bot commented on KAFKA-8179: --- ableegoldman commented on pull request #7100: KAFKA-8179:

[jira] [Commented] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-8179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892296#comment-16892296 ] ASF GitHub Bot commented on KAFKA-8179: --- ableegoldman commented on pull request #7107: KAFKA-8179:

[jira] [Updated] (KAFKA-8703) Move PartitionAssignor to public API

[ https://issues.apache.org/jira/browse/KAFKA-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8703: --- Description: Currently the PartitionAssignor, which is meant to be a pluggable

[jira] [Assigned] (KAFKA-8704) Add PartitionAssignor adapter for backwards compatibility

[ https://issues.apache.org/jira/browse/KAFKA-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-8704: -- Assignee: Sophie Blee-Goldman > Add PartitionAssignor adapter for backwards

[jira] [Commented] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-8179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892294#comment-16892294 ] ASF GitHub Bot commented on KAFKA-8179: --- ableegoldman commented on pull request #7110: KAFKA-8179:

[jira] [Updated] (KAFKA-8712) Build Kafka Streams against Scala 2.13

[ https://issues.apache.org/jira/browse/KAFKA-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Loic DIVAD updated KAFKA-8712: -- Description: Since Scala 2.13 has been released and KAFKA-7197 brings its support, the library

[jira] [Commented] (KAFKA-8712) Build Kafka Streams against Scala 2.13

[ https://issues.apache.org/jira/browse/KAFKA-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892261#comment-16892261 ] Ismael Juma commented on KAFKA-8712: That's my expectation and hence why I was asking the question.

[jira] [Commented] (KAFKA-8712) Build Kafka Streams against Scala 2.13

[ https://issues.apache.org/jira/browse/KAFKA-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892260#comment-16892260 ] Matthias J. Sax commented on KAFKA-8712: [~ijuma] Are you saying, that we don't need to do

[jira] [Updated] (KAFKA-8712) Build Kafka Streams against Scala 2.13

[ https://issues.apache.org/jira/browse/KAFKA-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8712: --- Fix Version/s: 2.4.0 > Build Kafka Streams against Scala 2.13 >

[jira] [Updated] (KAFKA-8712) Build Kafka Streams against Scala 2.13

[ https://issues.apache.org/jira/browse/KAFKA-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8712: --- Affects Version/s: (was: 2.3.0) > Build Kafka Streams against Scala 2.13 >

[jira] [Commented] (KAFKA-8712) Build Kafka Streams against Scala 2.13

[ https://issues.apache.org/jira/browse/KAFKA-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892257#comment-16892257 ] Ismael Juma commented on KAFKA-8712: It should be. Do you have reason to believe it's not? > Build

[jira] [Updated] (KAFKA-8712) Build Kafka Streams against Scala 2.13

[ https://issues.apache.org/jira/browse/KAFKA-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Loic DIVAD updated KAFKA-8712: -- Issue Type: Wish (was: New Feature) > Build Kafka Streams against Scala 2.13 >

[jira] [Created] (KAFKA-8712) Build Kafka Streams against Scala 2.13

Loic DIVAD created KAFKA-8712: - Summary: Build Kafka Streams against Scala 2.13 Key: KAFKA-8712 URL: https://issues.apache.org/jira/browse/KAFKA-8712 Project: Kafka Issue Type: New Feature

[jira] [Commented] (KAFKA-8705) NullPointerException was thrown by topology optimization when two MergeNodes have common KeyChaingingNode

[ https://issues.apache.org/jira/browse/KAFKA-8705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892228#comment-16892228 ] ASF GitHub Bot commented on KAFKA-8705: --- bbejeck commented on pull request #7109: KAFKA-8705:

[jira] [Commented] (KAFKA-8705) NullPointerException was thrown by topology optimization when two MergeNodes have common KeyChaingingNode

[ https://issues.apache.org/jira/browse/KAFKA-8705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892227#comment-16892227 ] ASF GitHub Bot commented on KAFKA-8705: --- bbejeck commented on pull request #7109: KAFKA-8705:

[jira] [Commented] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-8179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892184#comment-16892184 ] ASF GitHub Bot commented on KAFKA-8179: --- ableegoldman commented on pull request #7108: KAFKA-8179:

[jira] [Commented] (KAFKA-8673) Kafka stream threads stuck while sending offsets to transaction preventing join group from completing

[ https://issues.apache.org/jira/browse/KAFKA-8673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892132#comment-16892132 ] Guozhang Wang commented on KAFKA-8673: -- Also cc [~bob-barrett] [~hachikuji] who has been looking to

[jira] [Commented] (KAFKA-8673) Kafka stream threads stuck while sending offsets to transaction preventing join group from completing

[ https://issues.apache.org/jira/browse/KAFKA-8673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892129#comment-16892129 ] Guozhang Wang commented on KAFKA-8673: -- Yes, but my main point is that the `AddOffsetsToTxn` should

[jira] [Commented] (KAFKA-8711) Kafka 2.3.0 Transient Unit Test Failures SocketServerTest. testControlPlaneRequest

[ https://issues.apache.org/jira/browse/KAFKA-8711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892118#comment-16892118 ] Chandrasekhar commented on KAFKA-8711: -- Attached find the logs...Please let us know if we can

[jira] [Updated] (KAFKA-8711) Kafka 2.3.0 Transient Unit Test Failures SocketServerTest. testControlPlaneRequest

[ https://issues.apache.org/jira/browse/KAFKA-8711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandrasekhar updated KAFKA-8711: - Attachment: KafkaUTFailures07242019_PASS2.GIF > Kafka 2.3.0 Transient Unit Test Failures

[jira] [Created] (KAFKA-8711) Kafka 2.3.0 Transient Unit Test Failures SocketServerTest. testControlPlaneRequest

Chandrasekhar created KAFKA-8711: Summary: Kafka 2.3.0 Transient Unit Test Failures SocketServerTest. testControlPlaneRequest Key: KAFKA-8711 URL: https://issues.apache.org/jira/browse/KAFKA-8711

[jira] [Updated] (KAFKA-8706) Kafka 2.3.0 Transient Unit Test Failures on Oracle Linux - See attached for details

[ https://issues.apache.org/jira/browse/KAFKA-8706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandrasekhar updated KAFKA-8706: - Priority: Major (was: Minor) Summary: Kafka 2.3.0 Transient Unit Test Failures on Oracle

[jira] [Updated] (KAFKA-8706) Kafka 2.3.0 Unit Test Failures on Oracle Linux - Need help debugging framework or issue.

[ https://issues.apache.org/jira/browse/KAFKA-8706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandrasekhar updated KAFKA-8706: - Component/s: unit tests > Kafka 2.3.0 Unit Test Failures on Oracle Linux - Need help debugging

[jira] [Commented] (KAFKA-8673) Kafka stream threads stuck while sending offsets to transaction preventing join group from completing

[ https://issues.apache.org/jira/browse/KAFKA-8673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892075#comment-16892075 ] Boyang Chen commented on KAFKA-8673: [~guozhang] Just to clarify, the `AddOffsetsToTxn` request

[jira] [Commented] (KAFKA-8706) Kafka 2.3.0 Unit Test Failures on Oracle Linux - Need help debugging framework or issue.

[ https://issues.apache.org/jira/browse/KAFKA-8706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892055#comment-16892055 ] Chandrasekhar commented on KAFKA-8706: -- Second Pass: Failed Test Cases: 3, per your list above:

[jira] [Updated] (KAFKA-8706) Kafka 2.3.0 Unit Test Failures on Oracle Linux - Need help debugging framework or issue.

[ https://issues.apache.org/jira/browse/KAFKA-8706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandrasekhar updated KAFKA-8706: - Attachment: KafkaUTFailures07242019_PASS2.GIF > Kafka 2.3.0 Unit Test Failures on Oracle Linux

[jira] [Updated] (KAFKA-8706) Kafka 2.3.0 Unit Test Failures on Oracle Linux - Need help debugging framework or issue.

[ https://issues.apache.org/jira/browse/KAFKA-8706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandrasekhar updated KAFKA-8706: - Attachment: KafkaAUTFailures07242019_PASS2.txt > Kafka 2.3.0 Unit Test Failures on Oracle Linux

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892046#comment-16892046 ] Bob Barrett commented on KAFKA-7190: The periodic producer expiration check expires producers if 1)

[jira] [Commented] (KAFKA-8673) Kafka stream threads stuck while sending offsets to transaction preventing join group from completing

[ https://issues.apache.org/jira/browse/KAFKA-8673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892014#comment-16892014 ] Varsha Abhinandan commented on KAFKA-8673: -- Hi [~guozhang], the threads were blocked on 

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891992#comment-16891992 ] Raman Gupta commented on KAFKA-7190: > Did you override message.timestamp.difference.max.ms? No. >

[jira] [Updated] (KAFKA-8709) improve consumer offsets resiliency

[ https://issues.apache.org/jira/browse/KAFKA-8709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christian Becker updated KAFKA-8709: Description: We attempted to do an update from 2.2 to 2.3 and then a rollback was done

[jira] [Commented] (KAFKA-7940) Flaky Test CustomQuotaCallbackTest#testCustomQuotaCallback

[ https://issues.apache.org/jira/browse/KAFKA-7940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891987#comment-16891987 ] Matthias J. Sax commented on KAFKA-7940:

[jira] [Updated] (KAFKA-8122) Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState

[ https://issues.apache.org/jira/browse/KAFKA-8122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8122: --- Affects Version/s: 2.4.0 > Flaky Test

[jira] [Commented] (KAFKA-8122) Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState

[ https://issues.apache.org/jira/browse/KAFKA-8122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891988#comment-16891988 ] Matthias J. Sax commented on KAFKA-8122:

[jira] [Commented] (KAFKA-8589) Flakey test ResetConsumerGroupOffsetTest#testResetOffsetsExistingTopic

[ https://issues.apache.org/jira/browse/KAFKA-8589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891985#comment-16891985 ] Matthias J. Sax commented on KAFKA-8589:

[jira] [Commented] (KAFKA-8671) NullPointerException occurs if topic associated with GlobalKTable changes

[ https://issues.apache.org/jira/browse/KAFKA-8671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891984#comment-16891984 ] Alex Leung commented on KAFKA-8671: --- Thanks for taking a look, [~guozhang]. I also wanted to add a unit

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891976#comment-16891976 ] Guozhang Wang commented on KAFKA-7190: -- Hmm interesting, in this case the topic is not a repartition

[jira] [Created] (KAFKA-8710) InitProducerId changes for KIP-360

Bob Barrett created KAFKA-8710: -- Summary: InitProducerId changes for KIP-360 Key: KAFKA-8710 URL: https://issues.apache.org/jira/browse/KAFKA-8710 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-8671) NullPointerException occurs if topic associated with GlobalKTable changes

[ https://issues.apache.org/jira/browse/KAFKA-8671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891971#comment-16891971 ] Guozhang Wang commented on KAFKA-8671: -- I looked at the diff and it looks promising to me. Could

[jira] [Commented] (KAFKA-8396) Clean up Transformer API

[ https://issues.apache.org/jira/browse/KAFKA-8396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891913#comment-16891913 ] John Roesler commented on KAFKA-8396: - >From the discussion of KIP-478, Guozhang had the following

[jira] [Commented] (KAFKA-8706) Kafka 2.3.0 Unit Test Failures on Oracle Linux - Need help debugging framework or issue.

[ https://issues.apache.org/jira/browse/KAFKA-8706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891890#comment-16891890 ] Chandrasekhar commented on KAFKA-8706: -- Re-running just one more time to confirm, if we hit these 3

[jira] [Comment Edited] (KAFKA-8705) NullPointerException was thrown by topology optimization when two MergeNodes have common KeyChaingingNode

[ https://issues.apache.org/jira/browse/KAFKA-8705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891887#comment-16891887 ] Bill Bejeck edited comment on KAFKA-8705 at 7/24/19 2:12 PM: - [~hiro116s] 

[jira] [Commented] (KAFKA-8705) NullPointerException was thrown by topology optimization when two MergeNodes have common KeyChaingingNode

[ https://issues.apache.org/jira/browse/KAFKA-8705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891887#comment-16891887 ] Bill Bejeck commented on KAFKA-8705: [~hiro116s] thanks for reporting this, we'll take a look into

[jira] [Comment Edited] (KAFKA-8706) Kafka 2.3.0 Unit Test Failures on Oracle Linux - Need help debugging framework or issue.

[ https://issues.apache.org/jira/browse/KAFKA-8706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891872#comment-16891872 ] Chandrasekhar edited comment on KAFKA-8706 at 7/24/19 2:08 PM: --- [~ckamal]:

[jira] [Assigned] (KAFKA-8705) NullPointerException was thrown by topology optimization when two MergeNodes have common KeyChaingingNode

[ https://issues.apache.org/jira/browse/KAFKA-8705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8705: -- Assignee: Bill Bejeck > NullPointerException was thrown by topology optimization when two

[jira] [Commented] (KAFKA-8706) Kafka 2.3.0 Unit Test Failures on Oracle Linux - Need help debugging framework or issue.

[ https://issues.apache.org/jira/browse/KAFKA-8706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891872#comment-16891872 ] Chandrasekhar commented on KAFKA-8706: -- Reran the AUT again, and found four failures. The following

[jira] [Updated] (KAFKA-8706) Kafka 2.3.0 Unit Test Failures on Oracle Linux - Need help debugging framework or issue.

[ https://issues.apache.org/jira/browse/KAFKA-8706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandrasekhar updated KAFKA-8706: - Attachment: KafkaUTFailures07242019.GIF > Kafka 2.3.0 Unit Test Failures on Oracle Linux - Need

[jira] [Updated] (KAFKA-8706) Kafka 2.3.0 Unit Test Failures on Oracle Linux - Need help debugging framework or issue.

[ https://issues.apache.org/jira/browse/KAFKA-8706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandrasekhar updated KAFKA-8706: - Attachment: KafkaAUTFailures07242019.txt > Kafka 2.3.0 Unit Test Failures on Oracle Linux -

[jira] [Created] (KAFKA-8709) hard fail on "Unknown group metadata version"

Christian Becker created KAFKA-8709: --- Summary: hard fail on "Unknown group metadata version" Key: KAFKA-8709 URL: https://issues.apache.org/jira/browse/KAFKA-8709 Project: Kafka Issue

[jira] [Updated] (KAFKA-8709) improve consumer offsets resiliency

[ https://issues.apache.org/jira/browse/KAFKA-8709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christian Becker updated KAFKA-8709: Summary: improve consumer offsets resiliency (was: hard fail on "Unknown group metadata

[jira] [Assigned] (KAFKA-7213) NullPointerException during state restoration in kafka streams

[ https://issues.apache.org/jira/browse/KAFKA-7213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhishek Agarwal reassigned KAFKA-7213: --- Assignee: (was: Abhishek Agarwal) > NullPointerException during state

[jira] [Commented] (KAFKA-8608) Broker shows WARN on reassignment partitions on new brokers: Replica LEO, follower position & Cache truncation

[ https://issues.apache.org/jira/browse/KAFKA-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891715#comment-16891715 ] Di Campo commented on KAFKA-8608: - Hi Lillian, I'm afraid I can't, If it happens again, which context do

[jira] [Commented] (KAFKA-8612) Broker removes consumers from CG, Streams app gets stuck

[ https://issues.apache.org/jira/browse/KAFKA-8612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891712#comment-16891712 ] Di Campo commented on KAFKA-8612: - I've upgraded to 2.3 in testing environment and for a week it hasn't

[jira] [Created] (KAFKA-8707) Zookeeper Session expired either before or while waiting for connection

Chethan Bheemaiah created KAFKA-8707: Summary: Zookeeper Session expired either before or while waiting for connection Key: KAFKA-8707 URL: https://issues.apache.org/jira/browse/KAFKA-8707

[jira] [Created] (KAFKA-8708) Zookeeper Session expired either before or while waiting for connection

Chethan Bheemaiah created KAFKA-8708: Summary: Zookeeper Session expired either before or while waiting for connection Key: KAFKA-8708 URL: https://issues.apache.org/jira/browse/KAFKA-8708

[jira] [Commented] (KAFKA-8706) Kafka 2.3.0 Unit Test Failures on Oracle Linux - Need help debugging framework or issue.

[ https://issues.apache.org/jira/browse/KAFKA-8706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891648#comment-16891648 ] Kamal Chandraprakash commented on KAFKA-8706: - Kafka have some transient test case failures.

[jira] [Commented] (KAFKA-8697) Kafka consumer group auto removal

[ https://issues.apache.org/jira/browse/KAFKA-8697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891642#comment-16891642 ] Kamal Chandraprakash commented on KAFKA-8697: - [~progovoy]