[jira] [Commented] (KAFKA-9244) Update of old FK reference on RHS should not trigger join result

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

[jira] [Commented] (KAFKA-9244) Update of old FK reference on RHS should not trigger join result

[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984174#comment-16984174 ] Matthias J. Sax commented on KAFKA-9244: Ah sorry. I mixed up something when read

[jira] [Assigned] (KAFKA-9244) Update of old FK reference on RHS should not trigger join result

[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9244: -- Assignee: Matthias J. Sax > Update of old FK reference on RHS should not trigger join

[jira] [Updated] (KAFKA-9244) Update of old FK reference on RHS should not trigger join result

[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kin Siu updated KAFKA-9244: --- Description: Perform a KTable-KTable foreign key join, after changing LHS FK reference from FK1 -> FK2, popu

[jira] [Commented] (KAFKA-9244) Update of old FK reference on RHS should not trigger join result

[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984139#comment-16984139 ] Matthias J. Sax commented on KAFKA-9244: {quote}mkEntry("lhs1", "(lhsValue1|rhs2,

[jira] [Issue Comment Deleted] (KAFKA-9244) Update of old FK reference on RHS should not trigger join result

[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9244: --- Comment: was deleted (was: {quote}mkEntry("lhs1", "(lhsValue1|rhs2,rhsValue2)")  <-- this is

[jira] [Comment Edited] (KAFKA-9244) Update of old FK reference on RHS should not trigger join result

[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984045#comment-16984045 ] Matthias J. Sax edited comment on KAFKA-9244 at 11/28/19 4:19 AM: -

[jira] [Comment Edited] (KAFKA-9244) Update of old FK reference on RHS should not trigger join result

[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984048#comment-16984048 ] Kin Siu edited comment on KAFKA-9244 at 11/28/19 2:37 AM: -- mkEnt

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984073#comment-16984073 ] Boyang Chen commented on KAFKA-8803: To be more specific, quoted from [~hachikuji]:

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984069#comment-16984069 ] Boyang Chen commented on KAFKA-8803: [~rocketraman] Thanks, so the issue happens spon

[jira] [Comment Edited] (KAFKA-9244) Update of old FK reference on RHS should not trigger join result

[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984048#comment-16984048 ] Kin Siu edited comment on KAFKA-9244 at 11/28/19 12:49 AM: --- mkE

[jira] [Updated] (KAFKA-9244) Update of old FK reference on RHS should not trigger join result

[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kin Siu updated KAFKA-9244: --- Description: Perform a KTable-KTable foreign key join, after changing LHS FK reference from FK1 -> FK2, popu

[jira] [Updated] (KAFKA-9244) Update of old FK reference on RHS should not trigger join result

[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kin Siu updated KAFKA-9244: --- Description: Perform a KTable-KTable foreign key join, after changing LHS FK reference from FK1 -> FK2, popu

[jira] [Commented] (KAFKA-9244) Update of old FK reference on RHS should not trigger join result

[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984048#comment-16984048 ] Kin Siu commented on KAFKA-9244: mkEntry("lhs1", "(lhsValue1|rhs2,rhsValue2)")  <-- this

[jira] [Commented] (KAFKA-9244) Update of old FK reference on RHS should not trigger join result

[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984045#comment-16984045 ] Matthias J. Sax commented on KAFKA-9244: In you last test case, right.pipeInput("

[jira] [Updated] (KAFKA-9243) Update the javadocs from KeyValueStore to TimestampKeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-9243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9243: --- Affects Version/s: 2.3.0 > Update the javadocs from KeyValueStore to TimestampKeyValueStore >

[jira] [Updated] (KAFKA-9243) Update the javadocs from KeyValueStore to TimestampKeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-9243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9243: --- Description: As of version 2.3, the DSL uses `TimestampedStores` to represent KTables. Howeve

[jira] [Updated] (KAFKA-9243) Update the javadocs from KeyValueStore to TimestampKeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-9243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9243: --- Component/s: (was: streams-test-utils) (was: producer )

[jira] [Updated] (KAFKA-9244) Update of old FK reference on RHS should not trigger join result

[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kin Siu updated KAFKA-9244: --- Description: Perform a KTable-KTable foreign key join, after changing LHS FK reference from FK1 -> FK2, popu

[jira] [Created] (KAFKA-9244) Update of old FK reference on RHS should not trigger join result

Kin Siu created KAFKA-9244: -- Summary: Update of old FK reference on RHS should not trigger join result Key: KAFKA-9244 URL: https://issues.apache.org/jira/browse/KAFKA-9244 Project: Kafka Issue Typ

[jira] [Commented] (KAFKA-7016) Reconsider the "avoid the expensive and useless stack trace for api exceptions" practice

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

[jira] [Commented] (KAFKA-9213) BufferOverflowException on rolling new segment after upgrading Kafka from 1.1.0 to 2.3.1

[ https://issues.apache.org/jira/browse/KAFKA-9213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983909#comment-16983909 ] Ismael Juma commented on KAFKA-9213: Thanks for the thorough investigation! Any thoug

[jira] [Commented] (KAFKA-9213) BufferOverflowException on rolling new segment after upgrading Kafka from 1.1.0 to 2.3.1

[ https://issues.apache.org/jira/browse/KAFKA-9213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983866#comment-16983866 ] Daniyar commented on KAFKA-9213: UPDATE: I've investigated another occurrence of this ex

[jira] [Commented] (KAFKA-9233) Kafka consumer throws undocumented IllegalStateException

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

[jira] [Assigned] (KAFKA-9233) Kafka consumer throws undocumented IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-9233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson reassigned KAFKA-9233: --- Assignee: Andrew Olson > Kafka consumer throws undocumented IllegalStateException >

[jira] [Commented] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic

[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983835#comment-16983835 ] Sophie Blee-Goldman commented on KAFKA-7663: [~twbecker] Those javadocs were

[jira] [Commented] (KAFKA-7016) Reconsider the "avoid the expensive and useless stack trace for api exceptions" practice

[ https://issues.apache.org/jira/browse/KAFKA-7016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983829#comment-16983829 ] Gary Russell commented on KAFKA-7016: - +1 - it's a total pain to have to do a text se

[jira] [Created] (KAFKA-9243) Update the javadocs from KeyValueStore to TimestampKeyValueStore

Walker Carlson created KAFKA-9243: - Summary: Update the javadocs from KeyValueStore to TimestampKeyValueStore Key: KAFKA-9243 URL: https://issues.apache.org/jira/browse/KAFKA-9243 Project: Kafka

[jira] [Comment Edited] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic

[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983797#comment-16983797 ] Tommy Becker edited comment on KAFKA-7663 at 11/27/19 6:25 PM:

[jira] [Commented] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic

[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983797#comment-16983797 ] Tommy Becker commented on KAFKA-7663: - Thanks for the comment [~vvcephei] . In the re

[jira] [Commented] (KAFKA-9087) ReplicaAlterLogDirs stuck and restart fails with java.lang.IllegalStateException: Offset mismatch for the future replica

[ https://issues.apache.org/jira/browse/KAFKA-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983768#comment-16983768 ] Vijay commented on KAFKA-9087: -- Is the above issue resolved? Am also facing same problem. [

[jira] [Created] (KAFKA-9242) Document MirrorMaker2 usage and use cases

Mickael Maison created KAFKA-9242: - Summary: Document MirrorMaker2 usage and use cases Key: KAFKA-9242 URL: https://issues.apache.org/jira/browse/KAFKA-9242 Project: Kafka Issue Type: Improve

[jira] [Commented] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983665#comment-16983665 ] Bill Bejeck commented on KAFKA-9225: I don't recall the conversation either, but it m

[jira] [Updated] (KAFKA-9190) Server leaves connections with expired authentication sessions open

[ https://issues.apache.org/jira/browse/KAFKA-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ron Dagostino updated KAFKA-9190: - Affects Version/s: 2.2.0 2.3.0 2.2.1 > Server leave

[jira] [Created] (KAFKA-9241) SASL Clients are not forced to re-authenticate if they don't leverage SaslAuthenticateRequest

Ron Dagostino created KAFKA-9241: Summary: SASL Clients are not forced to re-authenticate if they don't leverage SaslAuthenticateRequest Key: KAFKA-9241 URL: https://issues.apache.org/jira/browse/KAFKA-9241

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983584#comment-16983584 ] Raman Gupta commented on KAFKA-8803: [~bchen225242] actually only one eos app is aff

[jira] [Updated] (KAFKA-9240) Flaky test kafka.admin.ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker

[ https://issues.apache.org/jira/browse/KAFKA-9240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-9240: - Labels: flaky-test (was: ) > Flaky test > kafka.admin.ReassignPartitionsClusterTest.sho

[jira] [Commented] (KAFKA-9240) Flaky test kafka.admin.ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker

[ https://issues.apache.org/jira/browse/KAFKA-9240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983577#comment-16983577 ] Levani Kokhreidze commented on KAFKA-9240: -- [https://builds.apache.org/job/kafka

[jira] [Created] (KAFKA-9240) Flaky test kafka.admin.ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker

Levani Kokhreidze created KAFKA-9240: Summary: Flaky test kafka.admin.ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker Key: KAFKA-9240 URL: https://issues.apache.org/jira/browse/KAFKA-9240

[jira] [Commented] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983574#comment-16983574 ] Levani Kokhreidze commented on KAFKA-9013: -- [https://builds.apache.org/job/kafka

[jira] [Commented] (KAFKA-8773) Static membership protocol borks on re-used group id

[ https://issues.apache.org/jira/browse/KAFKA-8773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983506#comment-16983506 ] Boyang Chen commented on KAFKA-8773: Hey Raman, wondering whether you got a fix for t

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983504#comment-16983504 ] Boyang Chen commented on KAFKA-8803: [~rocketraman] Hey Raman, I'm currently investig

[jira] [Updated] (KAFKA-9239) Extreme amounts of logging done by unauthorized Kafka clients

[ https://issues.apache.org/jira/browse/KAFKA-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anders Eknert updated KAFKA-9239: - Description: Having experimented some with custom authorization options for Kafka on the broker

[jira] [Created] (KAFKA-9239) Extreme amounts of logging done by unauthorized Kafka clients

Anders Eknert created KAFKA-9239: Summary: Extreme amounts of logging done by unauthorized Kafka clients Key: KAFKA-9239 URL: https://issues.apache.org/jira/browse/KAFKA-9239 Project: Kafka

[jira] [Resolved] (KAFKA-9226) Section on deletion of segment files is out of date

[ https://issues.apache.org/jira/browse/KAFKA-9226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-9226. --- Fix Version/s: 2.5.0 Assignee: Sönke Liebau Resolution: Fixed > Section on de

[jira] [Commented] (KAFKA-9226) Section on deletion of segment files is out of date

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

[jira] [Resolved] (KAFKA-9219) NullPointerException when polling metrics from Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-9219. --- Fix Version/s: 2.5.0 Resolution: Fixed > NullPointerException when polling metrics fro

[jira] [Commented] (KAFKA-9219) NullPointerException when polling metrics from Kafka Connect

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

[jira] [Commented] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983311#comment-16983311 ] Bruno Cadonna commented on KAFKA-9225: -- I also do not remember that we agreed on wai