[jira] [Commented] (KAFKA-12478) Consumer group may lose data for newly expanded partitions when add partitions for topic if the group is set to consume from the latest

[ https://issues.apache.org/jira/browse/KAFKA-12478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310106#comment-17310106 ] Guozhang Wang commented on KAFKA-12478: --- Thanks [~hudeqi]. I think it is still better to implement

[jira] [Updated] (KAFKA-3370) Add options to auto.offset.reset to reset offsets upon initialization only

[ https://issues.apache.org/jira/browse/KAFKA-3370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3370: - Labels: needs-kip (was: ) > Add options to auto.offset.reset to reset offsets upon

[GitHub] [kafka] mjsax commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

mjsax commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602819590 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java ## @@ -816,6 +817,106 @@ public void

[GitHub] [kafka] mjsax commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

mjsax commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602819516 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java ## @@ -816,6 +817,106 @@ public void

[GitHub] [kafka] mjsax commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

mjsax commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602819333 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java ## @@ -816,6 +817,106 @@ public void

[GitHub] [kafka] mjsax commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

mjsax commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602818917 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java ## @@ -816,6 +817,106 @@ public void

[GitHub] [kafka] mjsax commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

mjsax commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602818500 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -972,42 +1004,60 @@ void addRecordsToTasks(final

[GitHub] [kafka] mjsax commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

mjsax commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602818286 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -972,42 +1004,60 @@ void addRecordsToTasks(final

[GitHub] [kafka] mjsax commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

mjsax commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602818286 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -972,42 +1004,60 @@ void addRecordsToTasks(final

[GitHub] [kafka] mjsax commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

mjsax commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602818043 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -972,42 +1004,60 @@ void addRecordsToTasks(final

[GitHub] [kafka] guozhangwang commented on a change in pull request #10421: KAFKA-12568: Remove deprecated APIs in KStream, KTable and Joined

guozhangwang commented on a change in pull request #10421: URL: https://github.com/apache/kafka/pull/10421#discussion_r602817335 ## File path: streams/src/test/java/org/apache/kafka/streams/StreamsBuilderTest.java ## @@ -725,12 +725,11 @@ public void

[GitHub] [kafka] guozhangwang opened a new pull request #10421: KAFKA-12568: Remove deprecated APIs in KStream, KTable and Joined

guozhangwang opened a new pull request #10421: URL: https://github.com/apache/kafka/pull/10421 *More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of

[GitHub] [kafka] mjsax commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

mjsax commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602817120 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -509,38 +517,64 @@ void handleRevocation(final

[jira] [Updated] (KAFKA-12568) Remove deprecated "KStream#groupBy/join", "Joined#named" overloads

[ https://issues.apache.org/jira/browse/KAFKA-12568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12568: Component/s: streams > Remove deprecated "KStream#groupBy/join", "Joined#named" overloads

[GitHub] [kafka] ableegoldman commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

ableegoldman commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602816050 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -155,40 +155,48 @@ void

[GitHub] [kafka] ableegoldman commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

ableegoldman commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602815829 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -155,40 +155,48 @@ void

[GitHub] [kafka] ableegoldman commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

ableegoldman commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602814084 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -509,38 +519,60 @@ void

[GitHub] [kafka] ableegoldman commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

ableegoldman commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602814576 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -509,38 +517,64 @@ void

[GitHub] [kafka] ableegoldman commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

ableegoldman commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602814576 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -509,38 +517,64 @@ void

[GitHub] [kafka] ableegoldman commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

ableegoldman commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602814034 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -509,38 +517,64 @@ void

[GitHub] [kafka] ableegoldman commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

ableegoldman commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602814224 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -155,40 +155,48 @@ void

[GitHub] [kafka] ableegoldman commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

ableegoldman commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602814084 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -509,38 +519,60 @@ void

[GitHub] [kafka] ableegoldman commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

ableegoldman commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602814034 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -509,38 +517,64 @@ void

[GitHub] [kafka] ableegoldman commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

ableegoldman commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602813910 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -509,38 +517,64 @@ void

[GitHub] [kafka] guozhangwang commented on a change in pull request #10378: KAFKA-7106: remove deprecated Windows APIs

guozhangwang commented on a change in pull request #10378: URL: https://github.com/apache/kafka/pull/10378#discussion_r602811233 ## File path: streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java ## @@ -73,33 +72,16 @@ public final class SessionWindows

[GitHub] [kafka] guozhangwang commented on a change in pull request #10378: KAFKA-7106: remove deprecated Windows APIs

guozhangwang commented on a change in pull request #10378: URL: https://github.com/apache/kafka/pull/10378#discussion_r602810827 ## File path: streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java ## @@ -42,66 +38,10 @@ */ public abstract class Windows { -

[GitHub] [kafka] guozhangwang commented on pull request #10412: KAFKA-12562: Remove deprecated APIs in KafkaStreams and returned state classes

guozhangwang commented on pull request #10412: URL: https://github.com/apache/kafka/pull/10412#issuecomment-808823710 @ableegoldman Thanks for the reviews. I will merge after green builds. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [kafka] guozhangwang commented on a change in pull request #10412: KAFKA-12562: Remove deprecated APIs in KafkaStreams and returned state classes

guozhangwang commented on a change in pull request #10412: URL: https://github.com/apache/kafka/pull/10412#discussion_r602810172 ## File path: docs/streams/upgrade-guide.html ## @@ -98,6 +98,9 @@ Streams API WindowBytesStoreSupplier#segments: deprecated

[jira] [Resolved] (KAFKA-12524) Remove deprecated WindowBytesStoreSupplier#segments

[ https://issues.apache.org/jira/browse/KAFKA-12524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-12524. --- Resolution: Fixed > Remove deprecated WindowBytesStoreSupplier#segments >

[jira] [Created] (KAFKA-12568) Remove deprecated "KStream#groupBy/join", "Joined#named" overloads

Guozhang Wang created KAFKA-12568: - Summary: Remove deprecated "KStream#groupBy/join", "Joined#named" overloads Key: KAFKA-12568 URL: https://issues.apache.org/jira/browse/KAFKA-12568 Project: Kafka

[GitHub] [kafka] guozhangwang commented on a change in pull request #10412: KAFKA-12562: Remove deprecated APIs in KafkaStreams and returned state classes

guozhangwang commented on a change in pull request #10412: URL: https://github.com/apache/kafka/pull/10412#discussion_r602809191 ## File path: docs/streams/upgrade-guide.html ## @@ -98,6 +98,9 @@ Streams API WindowBytesStoreSupplier#segments: deprecated

[jira] [Commented] (KAFKA-12499) Adjust transaction timeout according to commit interval on Streams EOS

[ https://issues.apache.org/jira/browse/KAFKA-12499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310098#comment-17310098 ] Guozhang Wang commented on KAFKA-12499: --- I also think checking commit interval < transaction

[jira] [Updated] (KAFKA-12499) Adjust transaction timeout according to commit interval on Streams EOS

[ https://issues.apache.org/jira/browse/KAFKA-12499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12499: -- Priority: Blocker (was: Major) > Adjust transaction timeout according to commit interval on

[jira] [Updated] (KAFKA-12462) Threads in PENDING_SHUTDOWN entering a rebalance can cause an illegal state exception

[ https://issues.apache.org/jira/browse/KAFKA-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12462: Affects Version/s: 2.7.0 > Threads in PENDING_SHUTDOWN entering a rebalance can cause an

[jira] [Commented] (KAFKA-12396) Dedicated exception for kstreams when null key received

[ https://issues.apache.org/jira/browse/KAFKA-12396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310097#comment-17310097 ] Matthias J. Sax commented on KAFKA-12396: - [~dvsingh9] Feel to assign the ticket to yourself and

[jira] [Commented] (KAFKA-12453) Guidance on whether a topology is eligible for optimisation

[ https://issues.apache.org/jira/browse/KAFKA-12453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310096#comment-17310096 ] Matthias J. Sax commented on KAFKA-12453: - I would need to double check the code, but I am not

[jira] [Commented] (KAFKA-12499) Adjust transaction timeout according to commit interval on Streams EOS

[ https://issues.apache.org/jira/browse/KAFKA-12499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310095#comment-17310095 ] Matthias J. Sax commented on KAFKA-12499: - Not sure if we can pick a reasonable default (even if

[jira] [Commented] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310093#comment-17310093 ] Matthias J. Sax commented on KAFKA-9552: >From my understanding, it's safe to catch

[jira] [Commented] (KAFKA-8531) Change default replication factor config

[ https://issues.apache.org/jira/browse/KAFKA-8531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310091#comment-17310091 ] Matthias J. Sax commented on KAFKA-8531: Yes, I plan to deliver this for 3.0. About 464: we

[jira] [Assigned] (KAFKA-10493) Ktable out-of-order updates are not being ignored

[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-10493: --- Assignee: Matthias J. Sax > Ktable out-of-order updates are not being ignored >

[jira] [Commented] (KAFKA-9559) Change the default "default serde" from ByteArraySerde to null

[ https://issues.apache.org/jira/browse/KAFKA-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310090#comment-17310090 ] Matthias J. Sax commented on KAFKA-9559: [~lct45] – I think we should also add corresponding

[jira] [Updated] (KAFKA-12562) Remove deprecated-overloaded "KafkaStreams#metadataForKey" and "KafkaStreams#store"

[ https://issues.apache.org/jira/browse/KAFKA-12562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12562: Component/s: streams > Remove deprecated-overloaded "KafkaStreams#metadataForKey" and >

[jira] [Updated] (KAFKA-12536) Add Instant-based methods to ReadOnlySessionStore

[ https://issues.apache.org/jira/browse/KAFKA-12536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12536: Component/s: streams > Add Instant-based methods to ReadOnlySessionStore >

[jira] [Updated] (KAFKA-12526) Remove deprecated long ms overloads

[ https://issues.apache.org/jira/browse/KAFKA-12526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12526: Component/s: streams > Remove deprecated long ms overloads >

[jira] [Updated] (KAFKA-12524) Remove deprecated WindowBytesStoreSupplier#segments

[ https://issues.apache.org/jira/browse/KAFKA-12524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12524: Component/s: streams > Remove deprecated WindowBytesStoreSupplier#segments >

[jira] [Updated] (KAFKA-12527) Remove deprecated "PartitionGrouper" interface

[ https://issues.apache.org/jira/browse/KAFKA-12527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12527: Component/s: streams > Remove deprecated "PartitionGrouper" interface >

[GitHub] [kafka] mjsax opened a new pull request #10420: MINOR: update Streams upgrade notes with removed APIs

mjsax opened a new pull request #10420: URL: https://github.com/apache/kafka/pull/10420 Follow up to #10284 and #10300 Call for review @guozhangwang @ableegoldman -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Commented] (KAFKA-12419) Remove Deprecated APIs of Kafka Streams in 3.0

[ https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310086#comment-17310086 ] Matthias J. Sax commented on KAFKA-12419: - SGTM.

[jira] [Comment Edited] (KAFKA-12506) Expand AdjustStreamThreadCountTest

[ https://issues.apache.org/jira/browse/KAFKA-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310085#comment-17310085 ] Aviral Srivastava edited comment on KAFKA-12506 at 3/27/21, 10:22 PM:

[jira] [Commented] (KAFKA-12506) Expand AdjustStreamThreadCountTest

[ https://issues.apache.org/jira/browse/KAFKA-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310085#comment-17310085 ] Aviral Srivastava commented on KAFKA-12506: --- Hi [~ableegoldman], I have created a new PR and

[GitHub] [kafka] mjsax commented on a change in pull request #10411: KAFKA-7606: Remove deprecated options from StreamsResetter

mjsax commented on a change in pull request #10411: URL: https://github.com/apache/kafka/pull/10411#discussion_r602799226 ## File path: core/src/main/scala/kafka/tools/StreamsResetter.java ## @@ -247,14 +246,10 @@ private void parseArguments(final String[] args) {

[GitHub] [kafka] kebab-mai-haddi opened a new pull request #10419: WIP: KAFKA-12521

kebab-mai-haddi opened a new pull request #10419: URL: https://github.com/apache/kafka/pull/10419 writes data to the Kafka topic as part of the test setup Change of behavior: set up Kafka Producer and publish data to a topic as part of the AdjustStreamThreadCountTest integration

[GitHub] [kafka] mjsax commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

mjsax commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602797242 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -509,38 +517,64 @@ void handleRevocation(final

[jira] [Resolved] (KAFKA-12564) KTable#filter-method called twice after aggregation

[ https://issues.apache.org/jira/browse/KAFKA-12564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12564. - Resolution: Not A Bug > KTable#filter-method called twice after aggregation >

[jira] [Commented] (KAFKA-12564) KTable#filter-method called twice after aggregation

[ https://issues.apache.org/jira/browse/KAFKA-12564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310082#comment-17310082 ] Matthias J. Sax commented on KAFKA-12564: - The observed behavior is expected. For `KTable`

[jira] [Commented] (KAFKA-10201) Update codebase to use more inclusive terms

[ https://issues.apache.org/jira/browse/KAFKA-10201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310078#comment-17310078 ] Xavier Léauté commented on KAFKA-10201: --- [~tombentley] if you know anyone that can help push this

[GitHub] [kafka] mjsax commented on a change in pull request #10407: KAFKA-12523: handle TaskCorruption during handleCorruption and handleRevocation

mjsax commented on a change in pull request #10407: URL: https://github.com/apache/kafka/pull/10407#discussion_r602781702 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -509,38 +519,60 @@ void handleRevocation(final

[jira] [Created] (KAFKA-12567) Flaky Test TransactionsTest.testFencingOnCommit

Matthias J. Sax created KAFKA-12567: --- Summary: Flaky Test TransactionsTest.testFencingOnCommit Key: KAFKA-12567 URL: https://issues.apache.org/jira/browse/KAFKA-12567 Project: Kafka Issue

[jira] [Created] (KAFKA-12566) Flaky Test MirrorConnectorsIntegrationSSLTest#testReplication

Matthias J. Sax created KAFKA-12566: --- Summary: Flaky Test MirrorConnectorsIntegrationSSLTest#testReplication Key: KAFKA-12566 URL: https://issues.apache.org/jira/browse/KAFKA-12566 Project: Kafka

[jira] [Commented] (KAFKA-12384) Flaky Test ListOffsetsRequestTest.testResponseIncludesLeaderEpoch

[ https://issues.apache.org/jira/browse/KAFKA-12384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310051#comment-17310051 ] Matthias J. Sax commented on KAFKA-12384: - Observed one more failing run. > Flaky Test

[jira] [Commented] (KAFKA-12377) Flaky Test SaslAuthenticatorTest#testSslClientAuthRequiredForSaslSslListener

[ https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310050#comment-17310050 ] Matthias J. Sax commented on KAFKA-12377: - Did not monitor the build recently, but saw 2 more

[jira] [Commented] (KAFKA-12509) Tighten up StateDirectory thread locking

[ https://issues.apache.org/jira/browse/KAFKA-12509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309964#comment-17309964 ] Ketul Gupta commented on KAFKA-12509: - [~ableegoldman]  . I have changed the map to have thread

[GitHub] [kafka] ketulgupta1995 commented on pull request #10418: KAFKA-12509 Tighten up StateDirectory thread locking

ketulgupta1995 commented on pull request #10418: URL: https://github.com/apache/kafka/pull/10418#issuecomment-808744779 @ableegoldman could you review this -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [kafka] ketulgupta1995 opened a new pull request #10418: KAFKA-12509 Tighten up StateDirectory thread locking

ketulgupta1995 opened a new pull request #10418: URL: https://github.com/apache/kafka/pull/10418 Modified LockAndOwner class to have Thread reference instead of just name *More detailed description of your change, if necessary. The PR title and PR message become the squashed