[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035117#comment-17035117 ] highluck commented on KAFKA-9455: - [~guozhang] I have one more question What do you thi

[jira] [Commented] (KAFKA-9479) Describe consumer group --all-groups shows header for each entry

[ https://issues.apache.org/jira/browse/KAFKA-9479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035110#comment-17035110 ] ASF GitHub Bot commented on KAFKA-9479: --- vetler commented on pull request #8096: KA

[jira] [Commented] (KAFKA-9479) Describe consumer group --all-groups shows header for each entry

[ https://issues.apache.org/jira/browse/KAFKA-9479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035111#comment-17035111 ] Vetle Leinonen-Roeim commented on KAFKA-9479: - Done! [https://github.com/apac

[jira] [Updated] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9509: --- Fix Version/s: 2.5.0 > Fix flaky test MirrorConnectorsIntegrationTest.testReplication > -

[jira] [Updated] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9509: --- Affects Version/s: (was: 2.4.1, 2.5.0) > Fix flaky test MirrorConnectorsIntegrationTest.t

[jira] [Updated] (KAFKA-9503) TopologyTestDriver processes intermediate results in the wrong order

[ https://issues.apache.org/jira/browse/KAFKA-9503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9503: --- Fix Version/s: 2.4.1 2.5.0 > TopologyTestDriver processes intermediate res

[jira] [Resolved] (KAFKA-9500) Foreign-Key Join creates an invalid topology

[ https://issues.apache.org/jira/browse/KAFKA-9500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9500. - Resolution: Fixed > Foreign-Key Join creates an invalid topology > --

[jira] [Commented] (KAFKA-9500) Foreign-Key Join creates an invalid topology

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

[jira] [Commented] (KAFKA-9541) Flaky Test DescribeConsumerGroupTest#testDescribeGroupMembersWithShortInitializationTimeout

[ https://issues.apache.org/jira/browse/KAFKA-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035042#comment-17035042 ] ASF GitHub Bot commented on KAFKA-9541: --- huxihx commented on pull request #8094: KA

[jira] [Resolved] (KAFKA-9503) TopologyTestDriver processes intermediate results in the wrong order

[ https://issues.apache.org/jira/browse/KAFKA-9503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9503. - Resolution: Fixed > TopologyTestDriver processes intermediate results in the wrong order > --

[jira] [Updated] (KAFKA-9541) Flaky Test DescribeConsumerGroupTest#testDescribeGroupMembersWithShortInitializationTimeout

[ https://issues.apache.org/jira/browse/KAFKA-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-9541: -- Summary: Flaky Test DescribeConsumerGroupTest#testDescribeGroupMembersWithShortInitializationTimeout (was: Fl

[jira] [Commented] (KAFKA-9541) Flaky Test DescribeConsumerGroupTest#testDescribeGroupWithShortInitializationTimeout

[ https://issues.apache.org/jira/browse/KAFKA-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035028#comment-17035028 ] huxihx commented on KAFKA-9541: --- Occasionally the captured exception is DisconnectedExcepti

[jira] [Created] (KAFKA-9541) Flaky Test DescribeConsumerGroupTest#testDescribeGroupWithShortInitializationTimeout

huxihx created KAFKA-9541: - Summary: Flaky Test DescribeConsumerGroupTest#testDescribeGroupWithShortInitializationTimeout Key: KAFKA-9541 URL: https://issues.apache.org/jira/browse/KAFKA-9541 Project: Kafka

[jira] [Resolved] (KAFKA-9487) Followup : KAFKA-9445(Allow fetching a key from a single partition); addressing code review comments

[ https://issues.apache.org/jira/browse/KAFKA-9487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navinder Brar resolved KAFKA-9487. -- Resolution: Fixed > Followup : KAFKA-9445(Allow fetching a key from a single partition); > add

[jira] [Commented] (KAFKA-9355) RocksDB statistics are removed from JMX when EOS enabled and empty local state dir

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

[jira] [Resolved] (KAFKA-9390) Non-key joining of KTable not compatible with confluent avro serdes

[ https://issues.apache.org/jira/browse/KAFKA-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9390. - Resolution: Fixed > Non-key joining of KTable not compatible with confluent avro serdes > ---

[jira] [Commented] (KAFKA-9390) Non-key joining of KTable not compatible with confluent avro serdes

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

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034927#comment-17034927 ] highluck commented on KAFKA-9455: - @Guozhang Thanks! it was helpful! > Consider using T

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034923#comment-17034923 ] Guozhang Wang commented on KAFKA-9455: -- No we do not need a new point API, the exist

[jira] [Updated] (KAFKA-9540) Application getting "Could not find the standby task 0_4 while closing it" error

[ https://issues.apache.org/jira/browse/KAFKA-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9540: --- Affects Version/s: 2.5.0 2.4.0 > Application getting "Could no

[jira] [Updated] (KAFKA-9540) Application getting "Could not find the standby task 0_4 while closing it" error

[ https://issues.apache.org/jira/browse/KAFKA-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9540: --- Fix Version/s: 2.4.1 > Application getting "Could not find the standby task 0_4 while

[jira] [Commented] (KAFKA-9540) Application getting "Could not find the standby task 0_4 while closing it" error

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

[jira] [Commented] (KAFKA-9540) Application getting "Could not find the standby task 0_4 while closing it" error

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

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034913#comment-17034913 ] highluck commented on KAFKA-9455: - @Guozhang Wang Thanks! you Want to add a new point ap

[jira] [Commented] (KAFKA-9540) Application getting "Could not find the standby task 0_4 while closing it" error

[ https://issues.apache.org/jira/browse/KAFKA-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034911#comment-17034911 ] Sophie Blee-Goldman commented on KAFKA-9540: Hey [~badai], thanks for the tic

[jira] [Resolved] (KAFKA-9483) Add Scala KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9483. Fix Version/s: 2.5.0 Resolution: Fixed > Add Scala KStream#toTable to the Streams DS

[jira] [Commented] (KAFKA-9483) Add Scala KStream#toTable to the Streams DSL

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

[jira] [Created] (KAFKA-9540) Application getting "Could not find the standby task 0_4 while closing it" error

Badai Aqrandista created KAFKA-9540: --- Summary: Application getting "Could not find the standby task 0_4 while closing it" error Key: KAFKA-9540 URL: https://issues.apache.org/jira/browse/KAFKA-9540

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034889#comment-17034889 ] Guozhang Wang commented on KAFKA-9455: -- >From the ReadOnlyWindowedStore interface:

[jira] [Commented] (KAFKA-9530) Flaky Test kafka.admin.DescribeConsumerGroupTest.testDescribeGroupWithShortInitializationTimeout

[ https://issues.apache.org/jira/browse/KAFKA-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034886#comment-17034886 ] Matthias J. Sax commented on KAFKA-9530: [https://builds.apache.org/job/kafka-pr-

[jira] [Issue Comment Deleted] (KAFKA-9530) Flaky Test kafka.admin.DescribeConsumerGroupTest.testDescribeGroupWithShortInitializationTimeout

[ https://issues.apache.org/jira/browse/KAFKA-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9530: --- Comment: was deleted (was: [https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/4643/test

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034887#comment-17034887 ] Matthias J. Sax commented on KAFKA-8110: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-9530) Flaky Test kafka.admin.DescribeConsumerGroupTest.testDescribeGroupWithShortInitializationTimeout

[ https://issues.apache.org/jira/browse/KAFKA-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034885#comment-17034885 ] Matthias J. Sax commented on KAFKA-9530: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-6607) Consumer Client and Kafka Streams lag not zero when input topic transactional

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

[jira] [Commented] (KAFKA-6607) Consumer Client and Kafka Streams lag not zero when input topic transactional

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

[jira] [Commented] (KAFKA-9479) Describe consumer group --all-groups shows header for each entry

[ https://issues.apache.org/jira/browse/KAFKA-9479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034881#comment-17034881 ] Jeff Kim commented on KAFKA-9479: - [~hachikuji] sounds good. [~ve...@roeim.net] could you

[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=17034850#comment-17034850 ] Ryanne Dolan commented on KAFKA-9013: - I'm seeing loglines like `Found 11 topic-parti

[jira] [Commented] (KAFKA-9479) Describe consumer group --all-groups shows header for each entry

[ https://issues.apache.org/jira/browse/KAFKA-9479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034832#comment-17034832 ] Jason Gustafson commented on KAFKA-9479: [~jeffkbkim] If you have not already sta

[jira] [Created] (KAFKA-9539) Add leader epoch in StopReplicaRequest

David Jacot created KAFKA-9539: -- Summary: Add leader epoch in StopReplicaRequest Key: KAFKA-9539 URL: https://issues.apache.org/jira/browse/KAFKA-9539 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-7052) ExtractField SMT throws NPE - needs clearer error message

[ https://issues.apache.org/jira/browse/KAFKA-7052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-7052. -- Fix Version/s: 2.4.1 2.3.2 2.5.0 2.2.3

[jira] [Updated] (KAFKA-9417) Integration test for new EOS model with vanilla Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-9417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9417: --- Description: We would like to extend the `TransactionMessageCopier` to use the new subscription mode

[jira] [Commented] (KAFKA-7052) ExtractField SMT throws NPE - needs clearer error message

[ https://issues.apache.org/jira/browse/KAFKA-7052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034777#comment-17034777 ] ASF GitHub Bot commented on KAFKA-7052: --- rhauch commented on pull request #8059: KA

[jira] [Commented] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034766#comment-17034766 ] Sophie Blee-Goldman commented on KAFKA-8940: Failed again for me (locally): {

[jira] [Assigned] (KAFKA-9538) Flaky Test `testResetOffsetsExportImportPlan`

[ https://issues.apache.org/jira/browse/KAFKA-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-9538: -- Assignee: huxihx (was: Jason Gustafson) > Flaky Test `testResetOffsetsExportImportPla

[jira] [Resolved] (KAFKA-8211) Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan

[ https://issues.apache.org/jira/browse/KAFKA-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8211. Resolution: Fixed Closing this one since new failures do not match the stacktrace. I've ope

[jira] [Created] (KAFKA-9538) Flaky Test `testResetOffsetsExportImportPlan`

Jason Gustafson created KAFKA-9538: -- Summary: Flaky Test `testResetOffsetsExportImportPlan` Key: KAFKA-9538 URL: https://issues.apache.org/jira/browse/KAFKA-9538 Project: Kafka Issue Type: B

[jira] [Resolved] (KAFKA-8616) Replace ApiVersionsRequest request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-8616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8616. Resolution: Duplicate > Replace ApiVersionsRequest request/response with automated protocol > -

[jira] [Assigned] (KAFKA-9535) Metadata not updated when consumer encounters FENCED_LEADER_EPOCH

[ https://issues.apache.org/jira/browse/KAFKA-9535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9535: -- Assignee: Boyang Chen > Metadata not updated when consumer encounters FENCED_LEADER_EPOCH > --

[jira] [Updated] (KAFKA-9535) Metadata not updated when consumer encounters FENCED_LEADER_EPOCH

[ https://issues.apache.org/jira/browse/KAFKA-9535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9535: --- Description: Inside the consumer Fetcher's handling of ListOffsetResponse, if we hit `FENCED_LEADER_

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034746#comment-17034746 ] Sophie Blee-Goldman commented on KAFKA-8037: [~pkleindl] [~vvcephei] [~mjsax]

[jira] [Commented] (KAFKA-9537) Abstract transformations in configurations cause unfriendly error message.

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

[jira] [Commented] (KAFKA-6266) Kafka 1.0.0 : Repeated occurrence of WARN Resetting first dirty offset of __consumer_offsets-xx to log start offset 203569 since the checkpointed offset 120955 is inval

[ https://issues.apache.org/jira/browse/KAFKA-6266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034701#comment-17034701 ] ASF GitHub Bot commented on KAFKA-6266: --- splett2 commented on pull request #8089: K

[jira] [Commented] (KAFKA-9181) Flaky test kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe

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

[jira] [Created] (KAFKA-9537) Abstract transformations in configurations cause unfriendly error message.

Jeremy Custenborder created KAFKA-9537: -- Summary: Abstract transformations in configurations cause unfriendly error message. Key: KAFKA-9537 URL: https://issues.apache.org/jira/browse/KAFKA-9537

[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=17034661#comment-17034661 ] Matthias J. Sax commented on KAFKA-9013: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-6793) Unnecessary warning log message

[ https://issues.apache.org/jira/browse/KAFKA-6793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034616#comment-17034616 ] John Roesler commented on KAFKA-6793: - It seems like we could fix this simply by not

[jira] [Commented] (KAFKA-7061) Enhanced log compaction

[ https://issues.apache.org/jira/browse/KAFKA-7061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034592#comment-17034592 ] Jun Rao commented on KAFKA-7061: [~senthilm-ms] : Sorry for the delay. I will review the

[jira] [Commented] (KAFKA-9107) Change input Type of configBackingStore for StandaloneHerder

[ https://issues.apache.org/jira/browse/KAFKA-9107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034570#comment-17034570 ] ASF GitHub Bot commented on KAFKA-9107: --- rhauch commented on pull request #7602: KA

[jira] [Commented] (KAFKA-9280) Duplicate messages are observed in ACK mode ALL

[ https://issues.apache.org/jira/browse/KAFKA-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034540#comment-17034540 ] Stanislav Kozlovski commented on KAFKA-9280: [~vikram484] this shouldn't happ

[jira] [Commented] (KAFKA-9515) Upgrade ZooKeeper to 3.5.7

[ https://issues.apache.org/jira/browse/KAFKA-9515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034526#comment-17034526 ] Ismael Juma commented on KAFKA-9515: Can we get the doc changes ready please? > Upgr

[jira] [Commented] (KAFKA-9515) Upgrade ZooKeeper to 3.5.7

[ https://issues.apache.org/jira/browse/KAFKA-9515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034514#comment-17034514 ] Ron Dagostino commented on KAFKA-9515: -- [~ijuma] I have learned something since [~rs

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034478#comment-17034478 ] highluck commented on KAFKA-9455: - [~guozhang] I have a question. Are you referring to

[jira] [Updated] (KAFKA-9483) Add Scala KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck updated KAFKA-9483: Description: [KIP-523: Add KStream#toTable to the Streams DSL|https://cwiki.apache.org/confluence/display/

[jira] [Commented] (KAFKA-4928) Add integration test for DumpLogSegments

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

[jira] [Commented] (KAFKA-9533) ValueTransform forwards `null` values

[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034298#comment-17034298 ] Bruno Cadonna commented on KAFKA-9533: -- [~mviamari] Thank you for opening this ticke