ijuma commented on pull request #8915:
URL: https://github.com/apache/kafka/pull/8915#issuecomment-650978942
One job passed, the other two had unrelated test failures.
This is an automated message from the Apache Git Service.
ijuma merged pull request #8915:
URL: https://github.com/apache/kafka/pull/8915
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the
dengziming commented on pull request #8941:
URL: https://github.com/apache/kafka/pull/8941#issuecomment-650987242
Hi, @abbccdda ,
Thank you for your reply, here are some of my understandings:
1. `ConsumerCoordinator` has 3 main parts, below are interactions between
the 3 parts.
ijuma commented on pull request #8579:
URL: https://github.com/apache/kafka/pull/8579#issuecomment-650999166
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
prgitpr opened a new pull request #8945:
URL: https://github.com/apache/kafka/pull/8945
To avoid potential dead loop in KafkaConsumerProducerDemo
Motivation:
If main throws InterruptedException After consumerThread start , the
consumerThread will not shutdown .
prgitpr closed pull request #8945:
URL: https://github.com/apache/kafka/pull/8945
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to th
prgitpr opened a new pull request #8946:
URL: https://github.com/apache/kafka/pull/8946
To avoid potential dead loop in KafkaConsumerProducerDemo
Motivation:
If main throws InterruptedException After consumerThread start , the
consumerThread will not shutdown .
Modifica
[
https://issues.apache.org/jira/browse/KAFKA-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147635#comment-17147635
]
Joost van de Wijgerd commented on KAFKA-9953:
-
Hi [~bchen225242] ,
I agree
Fabian Lange created KAFKA-10210:
Summary: Use templated log message for LogContext
Key: KAFKA-10210
URL: https://issues.apache.org/jira/browse/KAFKA-10210
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-10210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Lange updated KAFKA-10210:
-
Description:
We are using an error aggregation framework which uses the log4j/slf4j log
message
Tom Bentley created KAFKA-10211:
---
Summary: Add DirectoryConfigProvider
Key: KAFKA-10211
URL: https://issues.apache.org/jira/browse/KAFKA-10211
Project: Kafka
Issue Type: Improvement
dajac commented on a change in pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#discussion_r446893874
##
File path: core/src/test/scala/unit/kafka/admin/AclCommandTest.scala
##
@@ -130,22 +132,61 @@ class AclCommandTest extends ZooKeeperTestHarness with
Loggi
David Jacot created KAFKA-10212:
---
Summary: Describing a topic with the TopicCommand fails if
unauthorised to use ListPartitionReassignments API
Key: KAFKA-10212
URL: https://issues.apache.org/jira/browse/KAFKA-10212
dajac opened a new pull request #8947:
URL: https://github.com/apache/kafka/pull/8947
Since https://issues.apache.org/jira/browse/KAFKA-8834, describing topics
with the TopicCommand requires privileges to use ListPartitionReassignments or
fails to describe the topics with the following err
omkreddy commented on a change in pull request #8885:
URL: https://github.com/apache/kafka/pull/8885#discussion_r446976087
##
File path: core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala
##
@@ -800,7 +800,7 @@ class PlaintextConsumerTest extends BaseConsumer
omkreddy commented on pull request #8885:
URL: https://github.com/apache/kafka/pull/8885#issuecomment-651125144
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
vinothchandar opened a new pull request #8948:
URL: https://github.com/apache/kafka/pull/8948
…tests
- Preferred when version >= 2.6.0
- Small renaming to make context clearer
*More detailed description of your change,
if necessary. The PR title and PR message become
Vinoth Chandar created KAFKA-10213:
--
Summary: Prefer --bootstrap-server in ducktape tests for Kafka
clients
Key: KAFKA-10213
URL: https://issues.apache.org/jira/browse/KAFKA-10213
Project: Kafka
sasukerui commented on pull request #8942:
URL: https://github.com/apache/kafka/pull/8942#issuecomment-651137328
> Thanks for the PR. Is this causing incorrect behavior or is it just a
clean-up? Please note that PRs should target the master branch.
Thanks for your answer, I will pay atte
omkreddy commented on pull request #8947:
URL: https://github.com/apache/kafka/pull/8947#issuecomment-651140150
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
tombentley commented on a change in pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#discussion_r447002522
##
File path: core/src/test/scala/unit/kafka/admin/AclCommandTest.scala
##
@@ -130,22 +132,61 @@ class AclCommandTest extends ZooKeeperTestHarness with
[
https://issues.apache.org/jira/browse/KAFKA-5235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Urban reassigned KAFKA-5235:
---
Assignee: Daniel Urban
> GetOffsetShell: retrieve offsets for all given topics and partition
[
https://issues.apache.org/jira/browse/KAFKA-10212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10212:
--
Fix Version/s: 2.5.1
2.6.0
> Describing a topic with the TopicCommand fails
Chia-Ping Tsai created KAFKA-10214:
--
Summary: fix flaky zookeeper_tls_test.py
Key: KAFKA-10214
URL: https://issues.apache.org/jira/browse/KAFKA-10214
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-10214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-10214:
---
Description: After
https://github.com/apache/kafka/commit/3661f981fff2653aaf1d5ee0b6dde3410b
chia7712 opened a new pull request #8949:
URL: https://github.com/apache/kafka/pull/8949
After
https://github.com/apache/kafka/commit/3661f981fff2653aaf1d5ee0b6dde3410b5498db,
security_config is cached. Hence, the later changes to security flag can't
impact the security_config used by lat
chia7712 edited a comment on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-650923843
1. connect_rest_test.py is traced by #8944
2. zookeeper_tls_test.py is traced by #8949
This is an autom
[
https://issues.apache.org/jira/browse/KAFKA-5235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Urban updated KAFKA-5235:
Description: Currently, GetOffsetShell only allows fetching the offsets of
a single topic with an o
omkreddy commented on pull request #8947:
URL: https://github.com/apache/kafka/pull/8947#issuecomment-651157483
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
sasukerui opened a new pull request #8950:
URL: https://github.com/apache/kafka/pull/8950
Optimize the judgment condition of TopicMetadata parameters.
Judgment has been made in the method handleTopicMetadataRequest. like
authorizedTopics.isEmpty
if (authorizedTopics.isEmpty)
[
https://issues.apache.org/jira/browse/KAFKA-10158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147861#comment-17147861
]
Lucas Bradstreet commented on KAFKA-10158:
--
I think the problem here is subtly
vvcephei commented on pull request #8881:
URL: https://github.com/apache/kafka/pull/8881#issuecomment-651188643
Hey again @ConcurrencyPractitioner . I'm sorry to say that I still haven't
been able to review. It was a long week last week, resolving a subtle and
complex bug around upgrading
John Roesler created KAFKA-10215:
Summary: MockProcessorContext doesn't work with SessionStores
Key: KAFKA-10215
URL: https://issues.apache.org/jira/browse/KAFKA-10215
Project: Kafka
Issue Ty
[
https://issues.apache.org/jira/browse/KAFKA-10215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10215:
-
Description:
The recommended pattern for testing custom Processor implementations is to use
the
[
https://issues.apache.org/jira/browse/KAFKA-10215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10215:
-
Description:
The recommended pattern for testing custom Processor implementations is to use
the
[
https://issues.apache.org/jira/browse/KAFKA-10200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147885#comment-17147885
]
John Roesler commented on KAFKA-10200:
--
Created and linked https://issues.apache.or
dajac commented on pull request #8947:
URL: https://github.com/apache/kafka/pull/8947#issuecomment-651198590
@omkreddy I have opened https://github.com/apache/kafka/pull/8951 for 2.5.
This is an automated message from the Apa
dajac opened a new pull request #8951:
URL: https://github.com/apache/kafka/pull/8951
See https://github.com/apache/kafka/pull/8947
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
-
omkreddy commented on pull request #8951:
URL: https://github.com/apache/kafka/pull/8951#issuecomment-651199956
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/KAFKA-10158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147895#comment-17147895
]
Chia-Ping Tsai commented on KAFKA-10158:
[~lucasbradstreet] not sure whether I h
vvcephei commented on a change in pull request #8927:
URL: https://github.com/apache/kafka/pull/8927#discussion_r447071419
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextUtils.java
##
@@ -0,0 +1,39 @@
+/*
+ * Licensed to the Ap
[
https://issues.apache.org/jira/browse/KAFKA-10158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147907#comment-17147907
]
Lucas Bradstreet commented on KAFKA-10158:
--
For me that check passes and the fo
Jason Gustafson created KAFKA-10216:
---
Summary: Loosen permission for listing reassignments
Key: KAFKA-10216
URL: https://issues.apache.org/jira/browse/KAFKA-10216
Project: Kafka
Issue Type:
John Roesler created KAFKA-10217:
Summary: Move nodeLevelSensor and storeLevelSensor methods from
StreamsMetricsImpl to StreamsMetrics
Key: KAFKA-10217
URL: https://issues.apache.org/jira/browse/KAFKA-10217
cadonna commented on a change in pull request #8927:
URL: https://github.com/apache/kafka/pull/8927#discussion_r447080512
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextUtils.java
##
@@ -0,0 +1,39 @@
+/*
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/KAFKA-10216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-10216:
Description: Currently listing partition reassignments requires Cluster
Describe permissio
[
https://issues.apache.org/jira/browse/KAFKA-10158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147909#comment-17147909
]
Chia-Ping Tsai commented on KAFKA-10158:
Any suggestion about fixing the throttl
[
https://issues.apache.org/jira/browse/KAFKA-10217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10217:
-
Labels: kip-required newbie (was: newbie,)
> Move nodeLevelSensor and storeLevelSensor methods
[
https://issues.apache.org/jira/browse/KAFKA-10216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-10216:
---
Assignee: David Jacot
> Loosen permission for listing reassignments
> -
[
https://issues.apache.org/jira/browse/KAFKA-10217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10217:
-
Description:
StreamsMetricsImpl contains several convenience methods for safely registering
sen
vvcephei commented on pull request #8927:
URL: https://github.com/apache/kafka/pull/8927#issuecomment-651214440
Ok, @cadonna and @ableegoldman , I've addressed your feedback. WDYT?
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reassigned KAFKA-10091:
---
Assignee: Sophie Blee-Goldman
> Improve task idling
> ---
>
abbccdda commented on pull request #8913:
URL: https://github.com/apache/kafka/pull/8913#issuecomment-651219971
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
chia7712 commented on pull request #8913:
URL: https://github.com/apache/kafka/pull/8913#issuecomment-651221459
> Have you verified this test fix on local with docker?
Yep. It passes on my local. Waiting for the report of
https://jenkins.confluent.io/job/system-test-kafka-branch-bui
ableegoldman commented on pull request #8913:
URL: https://github.com/apache/kafka/pull/8913#issuecomment-651225638
AWS has been having "Increased Network Provisioning Latencies" so all the
system tests I tried to kick off over the past few days have failed. I'll try
one more time and if
[
https://issues.apache.org/jira/browse/KAFKA-10158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147923#comment-17147923
]
Lucas Bradstreet commented on KAFKA-10158:
--
[~chia7712] I'm quite sure what the
omkreddy commented on pull request #8947:
URL: https://github.com/apache/kafka/pull/8947#issuecomment-651228126
@dajac We have ambiguous reference error for scala 2.12
```
21:45:50 > Task :core:compileTestScala
21:45:50 [Error]
/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk
dajac commented on pull request #8947:
URL: https://github.com/apache/kafka/pull/8947#issuecomment-651233750
@omkreddy I just pushed a fix.
This is an automated message from the Apache Git Service.
To respond to the message,
dajac commented on pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#issuecomment-651234640
@mimaison Any progress on the rebase? ;)
This is an automated message from the Apache Git Service.
To respond to the
omkreddy commented on pull request #8947:
URL: https://github.com/apache/kafka/pull/8947#issuecomment-651237942
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
abbccdda commented on pull request #8925:
URL: https://github.com/apache/kafka/pull/8925#issuecomment-651243387
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
[
https://issues.apache.org/jira/browse/KAFKA-10158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147967#comment-17147967
]
Boyang Chen commented on KAFKA-10158:
-
failed again: [https://builds.apache.org/job/
[
https://issues.apache.org/jira/browse/KAFKA-10216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147971#comment-17147971
]
Colin McCabe commented on KAFKA-10216:
--
+1
> Loosen permission for listing reassig
omkreddy commented on pull request #8947:
URL: https://github.com/apache/kafka/pull/8947#issuecomment-651248917
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
rajinisivaram commented on pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#issuecomment-651250337
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, plea
rajinisivaram commented on pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#issuecomment-651250018
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, plea
andrewchoi5 opened a new pull request #8479:
URL: https://github.com/apache/kafka/pull/8479
KAFKA-9769: Finish operations for leaderEpoch-updated partitions up to point
ZK Exception occurs.
https://issues.apache.org/jira/browse/KAFKA-9769
For example, in such case, we will have th
andrewchoi5 commented on pull request #8479:
URL: https://github.com/apache/kafka/pull/8479#issuecomment-651253198
Thanks for the review @junrao -- let me know if there's anything else for
revision.
This is an automated mess
andrewchoi5 commented on pull request #8479:
URL: https://github.com/apache/kafka/pull/8479#issuecomment-651253282
Closed by accident.
This is an automated message from the Apache Git Service.
To respond to the message, plea
andrewchoi5 closed pull request #8479:
URL: https://github.com/apache/kafka/pull/8479
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go t
kkonstantine commented on pull request #8893:
URL: https://github.com/apache/kafka/pull/8893#issuecomment-651258204
2/3 builds are green, while the other one failed with 3 flaky MM2 tests.
Thanks @ijuma
This is an automa
abbccdda opened a new pull request #8952:
URL: https://github.com/apache/kafka/pull/8952
We are missing a `toString` logic in the RocksDbWindowBytesStoreSupplier,
such that the error log wasn't able to print out the supplier's actual config:
```
Exception in thread "main" org.apac
abbccdda commented on pull request #8952:
URL: https://github.com/apache/kafka/pull/8952#issuecomment-651258911
@ableegoldman @cadonna @vvcephei Call for review
This is an automated message from the Apache Git Service.
To res
kkonstantine merged pull request #8893:
URL: https://github.com/apache/kafka/pull/8893
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
[
https://issues.apache.org/jira/browse/KAFKA-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-10205:
Assignee: John Roesler
> NullPointerException in StreamTask (Kafka Streams 2.5.0)
> -
cgetzen commented on pull request #8930:
URL: https://github.com/apache/kafka/pull/8930#issuecomment-651268347
Much appreciated. Another property is the heartbeats topic.
I will create the KIP as soon as I get my head around all the different
types of configs and how they work together.
[
https://issues.apache.org/jira/browse/KAFKA-10194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17148030#comment-17148030
]
John Roesler commented on KAFKA-10194:
--
Hey [~chia7712] , can we just include this
[
https://issues.apache.org/jira/browse/KAFKA-10216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10216:
Component/s: core
> Loosen permission for listing reassignments
>
C0urante commented on a change in pull request #8910:
URL: https://github.com/apache/kafka/pull/8910#discussion_r447162953
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -138,6 +139,7 @@ public WorkerSinkTask(ConnectorTas
ableegoldman commented on pull request #8913:
URL: https://github.com/apache/kafka/pull/8913#issuecomment-651283162
Hey @chia7712 , since we're held up by the system tests anyway can we just
go ahead and put in the full fix I mentioned on the original ticket? ie, run
the reset tool between
ableegoldman opened a new pull request #8953:
URL: https://github.com/apache/kafka/pull/8953
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above
lct45 commented on pull request #8929:
URL: https://github.com/apache/kafka/pull/8929#issuecomment-651329753
@vvcephei @abbccdda this should be ready to be tested then merged!
This is an automated message from the Apache Git
kkonstantine merged pull request #8894:
URL: https://github.com/apache/kafka/pull/8894
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
abbccdda commented on a change in pull request #8953:
URL: https://github.com/apache/kafka/pull/8953#discussion_r447234048
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java
##
@@ -594,7 +594,7 @@ public static void waitFor
guozhangwang commented on pull request #8953:
URL: https://github.com/apache/kafka/pull/8953#issuecomment-651345158
LGTM.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
guozhangwang merged pull request #8953:
URL: https://github.com/apache/kafka/pull/8953
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
ConcurrencyPractitioner commented on pull request #8881:
URL: https://github.com/apache/kafka/pull/8881#issuecomment-651346146
@vvcephei Thanks for the thorough breakdown on what's going on! :) I will
take a look at the other operators then. :)
---
kkonstantine commented on pull request #8859:
URL: https://github.com/apache/kafka/pull/8859#issuecomment-651355001
Hi @akatona84
It's not clear to me why this would go to a patch/bugfix release branch. Do
we have a good reason to backport?
Additionally (and independently), note
abbccdda commented on pull request #8952:
URL: https://github.com/apache/kafka/pull/8952#issuecomment-651357330
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
akatona84 commented on pull request #8859:
URL: https://github.com/apache/kafka/pull/8859#issuecomment-651364492
Hi @kkonstantine , thx for explaining and taking care of these commits.
I was just hoping we could have it in 2.5.1 too.
I'll check CVEs related to the jetty version used in
rondagostino commented on pull request #8949:
URL: https://github.com/apache/kafka/pull/8949#issuecomment-651367068
@chia7712 The link in the description
https://github.com/apache/kafka/commit/3661f981fff2653aaf1d5ee0b6dde3410b5498db,%C2%A0security_config
does not resolve for me -- can you
[
https://issues.apache.org/jira/browse/KAFKA-6508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-6508:
---
Fix Version/s: 2.6.0
> Look into optimizing StreamPartitionAssignor StandbyTask Assig
[
https://issues.apache.org/jira/browse/KAFKA-6508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-6508.
Resolution: Fixed
This should be addressed via KIP-441
> Look into optimizing Stre
vvcephei commented on pull request #8929:
URL: https://github.com/apache/kafka/pull/8929#issuecomment-651387931
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
vvcephei commented on pull request #8929:
URL: https://github.com/apache/kafka/pull/8929#issuecomment-651388235
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
vvcephei commented on pull request #8927:
URL: https://github.com/apache/kafka/pull/8927#issuecomment-651388934
Test failures were unrelated:
org.apache.kafka.connect.mirror.MirrorConnectorsIntegrationTest.testReplication
Th
tdanylchuk edited a comment on pull request #7283:
URL: https://github.com/apache/kafka/pull/7283#issuecomment-651390594
+1 for having this in master
This is an automated message from the Apache Git Service.
To respond to the
tdanylchuk commented on pull request #7283:
URL: https://github.com/apache/kafka/pull/7283#issuecomment-651390594
+ 1 for having this in master
This is an automated message from the Apache Git Service.
To respond to the messa
abbccdda commented on pull request #8952:
URL: https://github.com/apache/kafka/pull/8952#issuecomment-651391283
@ableegoldman There is already one in the `InMemoryWindowBytesStoreSupplier`
This is an automated message from th
guozhangwang commented on pull request #8925:
URL: https://github.com/apache/kafka/pull/8925#issuecomment-651396758
test this
This is an automated message from the Apache Git Service.
To respond to the message, please log on
1 - 100 of 137 matches
Mail list logo
