[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&focusedCommentId=16851627#comment-16851627 ] wenxuanguan commented on KAFKA-4815: how transaction support multiple producer instan

[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&focusedCommentId=16851913#comment-16851913 ] SuryaTeja Duggi commented on KAFKA-7995: [~sagarrao] Can i get you mail so that i

[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] [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 (read/writ

[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 (read/writ

[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] [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&focusedCommentId=16851996#comment-16851996 ] ASF GitHub Bot commented on KAFKA-8187: --- bbejeck commented on pull request #6818: K

[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&focusedCommentId=16852015#comment-16852015 ] ASF GitHub Bot commented on KAFKA-8429: --- hachikuji commented on pull request #6811:

[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 ch

[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] [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&focusedCommentId=16852041#comment-16852041 ] Ismael Juma commented on KAFKA-8448: Nice find, thanks for the report. > Too many ka

[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 acro

[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&focusedCommentId=16852060#comment-16852060 ] ASF GitHub Bot commented on KAFKA-6455: --- mjsax commented on pull request #6751: KAF

[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] [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&focusedCommentId=16852127#comment-16852127 ] Guozhang Wang commented on KAFKA-8367: -- [~pavelsavov] Could you share the code of tr

[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&focusedCommentId=16852160#comment-16852160 ] Rens Groothuijsen commented on KAFKA-8293: -- I haven't been able to replicate thi

[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&focusedCommentId=16852247#comment-16852247 ] ASF GitHub Bot commented on KAFKA-8418: --- rhauch commented on pull request #6840: KA

[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] [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` bran

[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] [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&focusedCommentId=16852279#comment-16852279 ] Andrew Olson commented on KAFKA-8421: - Agree this would be a potentially quite benefi

[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&focusedCommentId=16852283#comment-16852283 ] ASF GitHub Bot commented on KAFKA-8155: --- mjsax commented on pull request #6596: KA

[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] [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] [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&focusedCommentId=16852379#comment-16852379 ] ASF GitHub Bot commented on KAFKA-5998: --- bbejeck commented on pull request #6846: K

[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 Issu

[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&focusedCommentId=16852397#comment-16852397 ] ASF GitHub Bot commented on KAFKA-8389: --- guozhangwang commented on pull request #67

[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&focusedCommentId=16852422#comment-16852422 ] ASF GitHub Bot commented on KAFKA-8199: --- guozhangwang commented on pull request #67

[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&focusedCommentId=16851300#comment-16851300 ] Richard Yu edited comment on KAFKA-8377 at 5/30/19 10:45 PM: -

[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&focusedCommentId=16852428#comment-16852428 ] Richard Yu commented on KAFKA-3539: --- [~radai] I don't know if this problem is resolved

[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&focusedCommentId=16852453#comment-16852453 ] Matthias J. Sax commented on KAFKA-8377: If we decide to materialize the upstream

[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: KStr

[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&focusedCommentId=16852473#comment-16852473 ] ASF GitHub Bot commented on KAFKA-8448: --- jolshan commented on pull request #6847: K

[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&focusedCommentId=16852478#comment-16852478 ] Guozhang Wang commented on KAFKA-8377: -- How about this: Update `valueGetterSupplier

[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] [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] [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&focusedCommentId=16852540#comment-16852540 ] ASF GitHub Bot commented on KAFKA-8452: --- vvcephei commented on pull request #6848:

[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-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&focusedCommentId=16852639#comment-16852639 ] Boyang Chen commented on KAFKA-8438: Hey Richard, thanks for the update. I'm still no

[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&focusedCommentId=16852639#comment-16852639 ] Boyang Chen edited comment on KAFKA-8438 at 5/31/19 4:20 AM: -

[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&focusedCommentId=16852639#comment-16852639 ] Boyang Chen edited comment on KAFKA-8438 at 5/31/19 4:20 AM: -

[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&focusedCommentId=16852643#comment-16852643 ] Richard Yu commented on KAFKA-8421: --- Might try to take a hack at this one. It certainly

[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&focusedCommentId=16852661#comment-16852661 ] ASF GitHub Bot commented on KAFKA-8187: --- hustclf commented on pull request #6849: K

[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 *RecordConverters#ByteBuffer.alloc

[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&focusedCommentId=16852686#comment-16852686 ] Matthias J. Sax commented on KAFKA-8377: Not sure if I can follow. The decision t

[jira] [Commented] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852699#comment-16852699 ] rita kuo commented on KAFKA-3410: - Ran into same issue today with kafka_2.11-1.1.1. Apply

[jira] [Updated] (KAFKA-8453) AdminClient describeTopic should handle partition level errors

[ https://issues.apache.org/jira/browse/KAFKA-8453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-8453: --- Description: The Metadata response may contain the following partition-level error codes: LEA

[jira] [Created] (KAFKA-8453) AdminClient describeTopic should handle partition level errors

Jason Gustafson created KAFKA-8453: -- Summary: AdminClient describeTopic should handle partition level errors Key: KAFKA-8453 URL: https://issues.apache.org/jira/browse/KAFKA-8453 Project: Kafka