[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852686#comment-16852686 ] Matthias J. Sax commented on KAFKA-8377: Not sure if I can follow. The decision to materialize or

[jira] [Updated] (KAFKA-8446) Kafka Streams restoration crashes with NPE when the record value is null

[ https://issues.apache.org/jira/browse/KAFKA-8446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8446: --- Description: To add more context here: a NPE will be triggered in

[jira] [Commented] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852661#comment-16852661 ] ASF GitHub Bot commented on KAFKA-8187: --- hustclf commented on pull request #6849: KAFKA-8187 Bugfix

[jira] [Commented] (KAFKA-8421) Allow consumer.poll() to return data in the middle of rebalance

[ https://issues.apache.org/jira/browse/KAFKA-8421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852643#comment-16852643 ] Richard Yu commented on KAFKA-8421: --- Might try to take a hack at this one. It certainly is an

[jira] [Comment Edited] (KAFKA-8438) Add API to allow user to define end behavior of consumer failure

[ https://issues.apache.org/jira/browse/KAFKA-8438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852639#comment-16852639 ] Boyang Chen edited comment on KAFKA-8438 at 5/31/19 4:20 AM: - Hey Richard,

[jira] [Comment Edited] (KAFKA-8438) Add API to allow user to define end behavior of consumer failure

[ https://issues.apache.org/jira/browse/KAFKA-8438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852639#comment-16852639 ] Boyang Chen edited comment on KAFKA-8438 at 5/31/19 4:20 AM: - Hey Richard,

[jira] [Commented] (KAFKA-8438) Add API to allow user to define end behavior of consumer failure

[ https://issues.apache.org/jira/browse/KAFKA-8438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852639#comment-16852639 ] Boyang Chen commented on KAFKA-8438: Hey Richard, thanks for the update. I'm still not quite clear

[jira] [Updated] (KAFKA-8451) transaction support multiple producer instance

[ https://issues.apache.org/jira/browse/KAFKA-8451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wenxuanguan updated KAFKA-8451: --- Description: It's common in distributed system that multiple producer instances send message in one

[jira] [Commented] (KAFKA-8452) Possible Suppress buffer optimization: de-duplicate prior value

[ https://issues.apache.org/jira/browse/KAFKA-8452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852540#comment-16852540 ] ASF GitHub Bot commented on KAFKA-8452: --- vvcephei commented on pull request #6848: KAFKA-8452:

[jira] [Created] (KAFKA-8452) Possible Suppress buffer optimization: de-duplicate prior value

John Roesler created KAFKA-8452: --- Summary: Possible Suppress buffer optimization: de-duplicate prior value Key: KAFKA-8452 URL: https://issues.apache.org/jira/browse/KAFKA-8452 Project: Kafka

[jira] [Created] (KAFKA-8451) transaction support multiple producer instance

wenxuanguan created KAFKA-8451: -- Summary: transaction support multiple producer instance Key: KAFKA-8451 URL: https://issues.apache.org/jira/browse/KAFKA-8451 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852478#comment-16852478 ] Guozhang Wang commented on KAFKA-8377: -- How about this: Update `valueGetterSupplier` to special

[jira] [Commented] (KAFKA-8448) Too many kafka.log.Log instances (Memory Leak)

[ https://issues.apache.org/jira/browse/KAFKA-8448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852473#comment-16852473 ] ASF GitHub Bot commented on KAFKA-8448: --- jolshan commented on pull request #6847: KAFKA-8448: Too

[jira] [Updated] (KAFKA-8446) Kafka Streams restoration crashes with NPE when the record value is null

[ https://issues.apache.org/jira/browse/KAFKA-8446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8446: --- Summary: Kafka Streams restoration crashes with NPE when the record value is null (was:

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852453#comment-16852453 ] Matthias J. Sax commented on KAFKA-8377: If we decide to materialize the upstream store for this

[jira] [Commented] (KAFKA-3539) KafkaProducer.send() may block even though it returns the Future

[ https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852428#comment-16852428 ] Richard Yu commented on KAFKA-3539: --- [~radai] I don't know if this problem is resolved or not. Issue

[jira] [Comment Edited] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16851300#comment-16851300 ] Richard Yu edited comment on KAFKA-8377 at 5/30/19 10:45 PM: - cc [~mjsax] How

[jira] [Commented] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

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

[jira] [Created] (KAFKA-8450) Augment processed in MockProcessor as KeyValueAndTimestamp

Guozhang Wang created KAFKA-8450: Summary: Augment processed in MockProcessor as KeyValueAndTimestamp Key: KAFKA-8450 URL: https://issues.apache.org/jira/browse/KAFKA-8450 Project: Kafka

[jira] [Commented] (KAFKA-8389) Duplicated MockProcessorSupplier / MockProcessor in TopologyTestDriverTest

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

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

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

[jira] [Resolved] (KAFKA-8441) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-8441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8441. -- Resolution: Invalid > Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[jira] [Resolved] (KAFKA-8440) Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows

[ https://issues.apache.org/jira/browse/KAFKA-8440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8440. -- Resolution: Invalid > Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows

[jira] [Commented] (KAFKA-8155) Update Streams system tests for 2.2.0 and 2.1.1 releases

[ https://issues.apache.org/jira/browse/KAFKA-8155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852283#comment-16852283 ] ASF GitHub Bot commented on KAFKA-8155: --- mjsax commented on pull request #6596: KAFKA-8155: Add

[jira] [Commented] (KAFKA-8421) Allow consumer.poll() to return data in the middle of rebalance

[ https://issues.apache.org/jira/browse/KAFKA-8421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852279#comment-16852279 ] Andrew Olson commented on KAFKA-8421: - Agree this would be a potentially quite beneficial

[jira] [Assigned] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-5998: -- Assignee: Bill Bejeck > /.checkpoint.tmp Not found exception >

[jira] [Resolved] (KAFKA-8418) Connect System tests are not waiting for REST resources to be registered

[ https://issues.apache.org/jira/browse/KAFKA-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-8418. -- Resolution: Fixed Reviewer: Randall Hauch Merged and backported all the way to `1.0`

[jira] [Updated] (KAFKA-8418) Connect System tests are not waiting for REST resources to be registered

[ https://issues.apache.org/jira/browse/KAFKA-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8418: - Fix Version/s: 2.2.1 2.1.2 2.0.2 1.1.2

[jira] [Commented] (KAFKA-8418) Connect System tests are not waiting for REST resources to be registered

[ https://issues.apache.org/jira/browse/KAFKA-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852247#comment-16852247 ] ASF GitHub Bot commented on KAFKA-8418: --- rhauch commented on pull request #6840: KAFKA-8418: Wait

[jira] [Commented] (KAFKA-8293) Messages undelivered when small quotas applied

[ https://issues.apache.org/jira/browse/KAFKA-8293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852160#comment-16852160 ] Rens Groothuijsen commented on KAFKA-8293: -- I haven't been able to replicate this issue with a

[jira] [Commented] (KAFKA-8367) Non-heap memory leak in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852127#comment-16852127 ] Guozhang Wang commented on KAFKA-8367: -- [~pavelsavov] Could you share the code of transformer /

[jira] [Resolved] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8187. Resolution: Fixed merged to trunk and cherry-picked to 2.3, 2.2 and 2.1 > State store record loss

[jira] [Updated] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8187: --- Fix Version/s: 2.2.1 2.1.2 2.3.0 > State store record loss

[jira] [Commented] (KAFKA-6455) Improve timestamp propagation at DSL level

[ https://issues.apache.org/jira/browse/KAFKA-6455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852060#comment-16852060 ] ASF GitHub Bot commented on KAFKA-6455: --- mjsax commented on pull request #6751: KAFKA-6455: Update

[jira] [Commented] (KAFKA-8448) Too many kafka.log.Log instances (Memory Leak)

[ https://issues.apache.org/jira/browse/KAFKA-8448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852041#comment-16852041 ] Ismael Juma commented on KAFKA-8448: Nice find, thanks for the report. > Too many kafka.log.Log

[jira] [Assigned] (KAFKA-8448) Too many kafka.log.Log instances (Memory Leak)

[ https://issues.apache.org/jira/browse/KAFKA-8448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Justine Olshan reassigned KAFKA-8448: - Assignee: Justine Olshan > Too many kafka.log.Log instances (Memory Leak) >

[jira] [Resolved] (KAFKA-8429) Consumer should handle offset change while OffsetForLeaderEpoch is inflight

[ https://issues.apache.org/jira/browse/KAFKA-8429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8429. Resolution: Fixed Fix Version/s: (was: 2.3.0) > Consumer should handle offset

[jira] [Commented] (KAFKA-8429) Consumer should handle offset change while OffsetForLeaderEpoch is inflight

[ https://issues.apache.org/jira/browse/KAFKA-8429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852015#comment-16852015 ] ASF GitHub Bot commented on KAFKA-8429: --- hachikuji commented on pull request #6811: KAFKA-8429;

[jira] [Commented] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

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

[jira] [Created] (KAFKA-8449) Restart task on reconfiguration under incremental cooperative rebalancing

Konstantine Karantasis created KAFKA-8449: - Summary: Restart task on reconfiguration under incremental cooperative rebalancing Key: KAFKA-8449 URL: https://issues.apache.org/jira/browse/KAFKA-8449

[jira] [Updated] (KAFKA-8448) Too many kafka.log.Log instances (Memory Leak)

[ https://issues.apache.org/jira/browse/KAFKA-8448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juan Olivares updated KAFKA-8448: - Description: We have a custom Kafka health check which creates a topic, add some ACLs

[jira] [Updated] (KAFKA-8448) Too many kafka.log.Log instances (Memory Leak)

[ https://issues.apache.org/jira/browse/KAFKA-8448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juan Olivares updated KAFKA-8448: - Description: We have a custom Kafka health check which creates a topic, add some ACLs

[jira] [Created] (KAFKA-8448) Too many kafka.log.Log instances (Memory Leak)

Juan Olivares created KAFKA-8448: Summary: Too many kafka.log.Log instances (Memory Leak) Key: KAFKA-8448 URL: https://issues.apache.org/jira/browse/KAFKA-8448 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-7995) Augment singleton protocol type to list for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-7995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16851913#comment-16851913 ] SuryaTeja Duggi commented on KAFKA-7995: [~sagarrao] Can i get you mail so that i can have some

[jira] [Commented] (KAFKA-4815) Idempotent/transactional Producer (KIP-98)

[ https://issues.apache.org/jira/browse/KAFKA-4815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16851627#comment-16851627 ] wenxuanguan commented on KAFKA-4815: how transaction support multiple producer instances. when

[jira] [Updated] (KAFKA-8447) New Metric to Measure Number of Tasks on a Connector

[ https://issues.apache.org/jira/browse/KAFKA-8447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cyrus Vafadari updated KAFKA-8447: -- Summary: New Metric to Measure Number of Tasks on a Connector (was: Add Connector-level