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

2019-11-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984184#comment-16984184 ] ASF GitHub Bot commented on KAFKA-9244: --- mjsax commented on pull request #7758: KAFKA-9244: Update

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

2019-11-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984174#comment-16984174 ] Matthias J. Sax commented on KAFKA-9244: Ah sorry. I mixed up something when reading your test

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

2019-11-27 Thread Matthias J. Sax (Jira)
[ 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

2019-11-27 Thread Kin Siu (Jira)
[ 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,

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

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

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

2019-11-27 Thread Matthias J. Sax (Jira)
[ 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

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

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

2019-11-27 Thread Kin Siu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984048#comment-16984048 ] Kin Siu edited comment on KAFKA-9244 at 11/28/19 2:37 AM: -- mkEntry("lhs1",

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

2019-11-27 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984073#comment-16984073 ] Boyang Chen commented on KAFKA-8803: To be more specific, quoted from [~hachikuji]: ``` we could

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

2019-11-27 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984069#comment-16984069 ] Boyang Chen commented on KAFKA-8803: [~rocketraman] Thanks, so the issue happens spontaneously

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

2019-11-27 Thread Kin Siu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984048#comment-16984048 ] Kin Siu edited comment on KAFKA-9244 at 11/28/19 12:49 AM: --- mkEntry("lhs1",

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

2019-11-27 Thread Kin Siu (Jira)
[ 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,

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

2019-11-27 Thread Kin Siu (Jira)
[ 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,

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

2019-11-27 Thread Kin Siu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984048#comment-16984048 ] Kin Siu commented on KAFKA-9244: mkEntry("lhs1", "(lhsValue1|rhs2,rhsValue2)")  <-- this is a line to

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

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

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

2019-11-27 Thread Matthias J. Sax (Jira)
[ 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

2019-11-27 Thread Matthias J. Sax (Jira)
[ 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.

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

2019-11-27 Thread Matthias J. Sax (Jira)
[ 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

2019-11-27 Thread Kin Siu (Jira)
[ 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,

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

2019-11-27 Thread Kin Siu (Jira)
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

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

2019-11-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983916#comment-16983916 ] ASF GitHub Bot commented on KAFKA-7016: --- ableegoldman commented on pull request #7756: KAFKA-7016:

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

2019-11-27 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983909#comment-16983909 ] Ismael Juma commented on KAFKA-9213: Thanks for the thorough investigation! Any thoughts [~junrao]?

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

2019-11-27 Thread Daniyar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983866#comment-16983866 ] Daniyar commented on KAFKA-9213: UPDATE: I've investigated another occurrence of this exception. For

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

2019-11-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983858#comment-16983858 ] ASF GitHub Bot commented on KAFKA-9233: --- noslowerdna commented on pull request #7755: KAFKA-9233:

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

2019-11-27 Thread Andrew Olson (Jira)
[ 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

2019-11-27 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983835#comment-16983835 ] Sophie Blee-Goldman commented on KAFKA-7663: [~twbecker] Those javadocs were added _because_

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

2019-11-27 Thread Gary Russell (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983829#comment-16983829 ] Gary Russell commented on KAFKA-7016: - +1 - it's a total pain to have to do a text search to figure

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

2019-11-27 Thread Walker Carlson (Jira)
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

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

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

2019-11-27 Thread Tommy Becker (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983797#comment-16983797 ] Tommy Becker commented on KAFKA-7663: - Thanks for the comment [~vvcephei] . In the reporter's

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

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

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

2019-11-27 Thread Mickael Maison (Jira)
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:

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

2019-11-27 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983665#comment-16983665 ] Bill Bejeck commented on KAFKA-9225: I don't recall the conversation either, but it makes sense to

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

2019-11-27 Thread Ron Dagostino (Jira)
[ 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

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

2019-11-27 Thread Ron Dagostino (Jira)
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

2019-11-27 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983584#comment-16983584 ] Raman Gupta commented on KAFKA-8803: [~bchen225242] actually only one eos app is affected (but

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

2019-11-27 Thread Levani Kokhreidze (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983577#comment-16983577 ] Levani Kokhreidze commented on KAFKA-9240: --

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

2019-11-27 Thread Levani Kokhreidze (Jira)
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

2019-11-27 Thread Levani Kokhreidze (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983574#comment-16983574 ] Levani Kokhreidze commented on KAFKA-9013: --

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

2019-11-27 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983506#comment-16983506 ] Boyang Chen commented on KAFKA-8773: Hey Raman, wondering whether you got a fix for this issue

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

2019-11-27 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983504#comment-16983504 ] Boyang Chen commented on KAFKA-8803: [~rocketraman] Hey Raman, I'm currently investigating this

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

2019-11-27 Thread Anders Eknert (Jira)
[ 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

2019-11-27 Thread Anders Eknert (Jira)
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

2019-11-27 Thread Mickael Maison (Jira)
[ 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

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

2019-11-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983460#comment-16983460 ] ASF GitHub Bot commented on KAFKA-9226: --- mimaison commented on pull request #7738: KAFKA-9226:

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

2019-11-27 Thread Mickael Maison (Jira)
[ 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

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

2019-11-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983449#comment-16983449 ] ASF GitHub Bot commented on KAFKA-9219: --- mimaison commented on pull request #7652: KAFKA-9219:

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

2019-11-27 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983311#comment-16983311 ] Bruno Cadonna commented on KAFKA-9225: -- I also do not remember that we agreed on waiting for 3.0. >