sndp2693 opened a new pull request #9243:
URL: https://github.com/apache/kafka/pull/9243
*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 testing
cnZach commented on pull request #9236:
URL: https://github.com/apache/kafka/pull/9236#issuecomment-685306709
Hi @omkreddy or @rajinisivaram , what do you think about this? I just want
to print out the error. It will be helpful for troubleshooting kerberos login
issue.
--
[
https://issues.apache.org/jira/browse/KAFKA-6585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188984#comment-17188984
]
Mani Jindal commented on KAFKA-6585:
hi [~guozhang] can you please help me which is s
ocadaruma opened a new pull request #9242:
URL: https://github.com/apache/kafka/pull/9242
- Current docs for replication quota config are bit confusing because they
contain a term "(for each topic)" though actually they work as upper bound for
"total" replication traffic listed in
`{leade
[
https://issues.apache.org/jira/browse/KAFKA-10457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Diachenko updated KAFKA-10457:
Summary: JsonConverter.toConnectData trims BigInteger to Long for
schema-less case
[
https://issues.apache.org/jira/browse/KAFKA-10457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Diachenko updated KAFKA-10457:
Priority: Critical (was: Major)
> JsonConverter.toConnectData trims BigInteger to
Oleksandr Diachenko created KAFKA-10457:
---
Summary: JsonConverter.toConnectData trims BigInteger to Double
for schema-less case
Key: KAFKA-10457
URL: https://issues.apache.org/jira/browse/KAFKA-10457
chia7712 commented on pull request #9223:
URL: https://github.com/apache/kafka/pull/9223#issuecomment-685290466
the failed build (jdk8 + scala 2.12) is related to #8955
This is an automated message from the Apache Git Service
chia7712 commented on pull request #8955:
URL: https://github.com/apache/kafka/pull/8955#issuecomment-685290261
```
[Warn]
/home/chia7712/kafka/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinScalaIntegrationTestImplicitSerdes.scala:22:
imported `Ser
ableegoldman commented on a change in pull request #9186:
URL: https://github.com/apache/kafka/pull/9186#discussion_r481602010
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java
##
@@ -58,23 +58,22 @@ public void init
showuon commented on pull request #9241:
URL: https://github.com/apache/kafka/pull/9241#issuecomment-685260150
@guozhangwang , could you help review this small PR? Thanks.
This is an automated message from the Apache Git Serv
showuon opened a new pull request #9241:
URL: https://github.com/apache/kafka/pull/9241
Add and update the Javadoc in `GroupMetadataManager.scala`
1. add missing parameters
2. rename the parameter name to be better understand and consistent ( change
from `group` to `groupId`)
3. fi
ableegoldman commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r481521637
##
File path: streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java
##
@@ -150,13 +185,25 @@
* @return an iterator over windowed
ableegoldman commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r481519774
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java
##
@@ -136,34 +174,64 @@
*
* This iterator mu
huxihx commented on pull request #9240:
URL: https://github.com/apache/kafka/pull/9240#issuecomment-685219138
@omkreddy please review this minor change. Thanks.
This is an automated message from the Apache Git Service.
To res
huxihx opened a new pull request #9240:
URL: https://github.com/apache/kafka/pull/9240
Fix typo in description of ConsoleProducer.
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
commen
ableegoldman commented on a change in pull request #9239:
URL: https://github.com/apache/kafka/pull/9239#discussion_r481518121
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -118,24 +121,28 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-10456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huxihx reassigned KAFKA-10456:
--
Assignee: huxihx
> wrong description in kafka-console-producer.sh help
>
ableegoldman commented on a change in pull request #9239:
URL: https://github.com/apache/kafka/pull/9239#discussion_r481518121
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -118,24 +121,28 @@ public void
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r481512388
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -118,24 +118,20 @@ public void
d8tltanc commented on pull request #7877:
URL: https://github.com/apache/kafka/pull/7877#issuecomment-685195411
Hi @jonathansantilli . Are you still working on this PR?
This is an automated message from the Apache Git Servic
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188870#comment-17188870
]
Jerry Wei commented on KAFKA-10134:
---
[~guozhang] thanks, I've tested clients changes i
[
https://issues.apache.org/jira/browse/KAFKA-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188864#comment-17188864
]
Sophie Blee-Goldman commented on KAFKA-10455:
-
Yeah ok, that sounds reasonab
cmccabe commented on pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#issuecomment-685182597
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
mumrah commented on pull request #9208:
URL: https://github.com/apache/kafka/pull/9208#issuecomment-685175756
@bbejeck update this branch with trunk and the PR builder should start
working
This is an automated message from t
bbejeck commented on pull request #9208:
URL: https://github.com/apache/kafka/pull/9208#issuecomment-685173764
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r481460413
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -192,29 +190,125 @@ public voi
danilo batista queiroz created KAFKA-10456:
--
Summary: wrong description in kafka-console-producer.sh help
Key: KAFKA-10456
URL: https://issues.apache.org/jira/browse/KAFKA-10456
Project: Kafka
mumrah merged pull request #9238:
URL: https://github.com/apache/kafka/pull/9238
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
vvcephei commented on pull request #8955:
URL: https://github.com/apache/kafka/pull/8955#issuecomment-685152475
Thanks so much for the contribution and your patience with our long
discussion, @LMnet !
This is an automated me
vvcephei merged pull request #8955:
URL: https://github.com/apache/kafka/pull/8955
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 t
vvcephei commented on a change in pull request #8955:
URL: https://github.com/apache/kafka/pull/8955#discussion_r481444344
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/serialization/Serdes.scala
##
@@ -43,12 +43,6 @@ object Serdes extends L
vvcephei commented on a change in pull request #8955:
URL: https://github.com/apache/kafka/pull/8955#discussion_r481441613
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/serialization/Serdes.scala
##
@@ -43,12 +43,6 @@ object Serdes extends L
vvcephei commented on a change in pull request #8834:
URL: https://github.com/apache/kafka/pull/8834#discussion_r481373305
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -446,14 +453,15 @@ boolean joinGroupIfNeede
chia7712 commented on a change in pull request #9238:
URL: https://github.com/apache/kafka/pull/9238#discussion_r481436430
##
File path: build.gradle
##
@@ -336,6 +337,7 @@ subprojects {
task integrationTest(type: Test, dependsOn: compileJava) {
maxParallelForks = use
cmccabe commented on pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#issuecomment-685130207
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
chia7712 commented on a change in pull request #9238:
URL: https://github.com/apache/kafka/pull/9238#discussion_r481417954
##
File path: Jenkinsfile
##
@@ -0,0 +1,169 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agr
[
https://issues.apache.org/jira/browse/KAFKA-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188804#comment-17188804
]
John Roesler commented on KAFKA-10455:
--
Thanks, [~ableegoldman] . This is a bummer.
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r481391993
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -192,29 +191,113 @@ public void proce
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r481378201
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -192,29 +191,113 @@ public void proce
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r481375834
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -164,11 +161,13 @@ public void proces
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r481338030
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -164,11 +161,13 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sharath Bhat reassigned KAFKA-6579:
---
Assignee: (was: Sharath Bhat)
> Consolidate window store and session store unit tests in
Sophie Blee-Goldman created KAFKA-10455:
---
Summary: Probing rebalances are not guaranteed to be triggered by
non-leader members
Key: KAFKA-10455
URL: https://issues.apache.org/jira/browse/KAFKA-10455
[
https://issues.apache.org/jira/browse/KAFKA-4279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rupesh Kumar Patel reassigned KAFKA-4279:
-
Assignee: Rupesh Kumar Patel
> REST endpoint to list converter plugins
> ---
[
https://issues.apache.org/jira/browse/KAFKA-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sandeep Kumar reassigned KAFKA-9440:
Assignee: Sandeep Kumar (was: Mani Jindal)
> Add ConsumerGroupCommand to delete static me
lct45 opened a new pull request #9239:
URL: https://github.com/apache/kafka/pull/9239
Adding a `backwardFetch` call to the window store for sliding windows
processing. While the implementation works with the forward call to the window
store, using `backwardFetch` allows for the iterator to
rhauch commented on a change in pull request #8918:
URL: https://github.com/apache/kafka/pull/8918#discussion_r481251133
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -475,7 +475,7 @@ private synchronized void recordSe
[
https://issues.apache.org/jira/browse/KAFKA-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sharath Bhat reassigned KAFKA-6579:
---
Assignee: Sharath Bhat
> Consolidate window store and session store unit tests into a single
mumrah commented on pull request #9226:
URL: https://github.com/apache/kafka/pull/9226#issuecomment-684931052
Closing in favor of #9238 for a clean slate
This is an automated message from the Apache Git Service.
To respond to
mumrah opened a new pull request #9238:
URL: https://github.com/apache/kafka/pull/9238
This PR adds a Jenkinsfile to the build to replace the existing jenkins.sh
script.
The build makes use of the parallel directive to run the JDK 8, 11, and 15
builds in parallel. Each build will re
mumrah closed pull request #9226:
URL: https://github.com/apache/kafka/pull/9226
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
[
https://issues.apache.org/jira/browse/KAFKA-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188534#comment-17188534
]
John Roesler commented on KAFKA-10454:
--
Huh, thanks for the report and repro, [~lko
mumrah commented on a change in pull request #9226:
URL: https://github.com/apache/kafka/pull/9226#discussion_r481202138
##
File path: Jenkinsfile
##
@@ -0,0 +1,200 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agree
[
https://issues.apache.org/jira/browse/KAFKA-10448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188447#comment-17188447
]
satya commented on KAFKA-10448:
---
[~mjsax] I would like to submit a request for KIP as you
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r480997443
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java
##
@@ -203,6 +203,10 @@ public String queryableStore
[
https://issues.apache.org/jira/browse/KAFKA-10072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188388#comment-17188388
]
victor commented on KAFKA-10072:
Hey [~akumar]
1. Limit the topic current to 1024B base
[
https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mani Jindal reassigned KAFKA-2939:
--
Assignee: Mani Jindal
> Make AbstractConfig.logUnused() tunable for clients
>
[
https://issues.apache.org/jira/browse/KAFKA-2865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mani Jindal reassigned KAFKA-2865:
--
Assignee: Mani Jindal
> Improve Request API Error Code Documention
> -
[
https://issues.apache.org/jira/browse/KAFKA-6585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mani Jindal reassigned KAFKA-6585:
--
Assignee: Mani Jindal
> Consolidate duplicated logic on reset tools
>
[
https://issues.apache.org/jira/browse/KAFKA-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mani Jindal reassigned KAFKA-9440:
--
Assignee: Mani Jindal
> Add ConsumerGroupCommand to delete static members
> --
[
https://issues.apache.org/jira/browse/KAFKA-7327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mani Jindal reassigned KAFKA-7327:
--
Assignee: (was: Mani Jindal)
> The CPU memory of the kafak master node continues to soar,
[
https://issues.apache.org/jira/browse/KAFKA-7327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mani Jindal reassigned KAFKA-7327:
--
Assignee: Mani Jindal
> The CPU memory of the kafak master node continues to soar, does not re
[
https://issues.apache.org/jira/browse/KAFKA-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188319#comment-17188319
]
Levani Kokhreidze edited comment on KAFKA-10454 at 9/1/20, 10:05 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188334#comment-17188334
]
Levani Kokhreidze edited comment on KAFKA-10454 at 9/1/20, 9:58 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188334#comment-17188334
]
Levani Kokhreidze commented on KAFKA-10454:
---
Workaround we have used so far is
[
https://issues.apache.org/jira/browse/KAFKA-5892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mani Jindal reassigned KAFKA-5892:
--
Assignee: Mani Jindal
> Connector property override does not work unless setting ALL converter
[
https://issues.apache.org/jira/browse/KAFKA-5892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mani Jindal reassigned KAFKA-5892:
--
Assignee: (was: Mani Jindal)
> Connector property override does not work unless setting AL
[
https://issues.apache.org/jira/browse/KAFKA-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Levani Kokhreidze updated KAFKA-10454:
--
Affects Version/s: 2.6.0
> Kafka Streams Stuck in infinite REBALANCING loop when strea
[
https://issues.apache.org/jira/browse/KAFKA-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Levani Kokhreidze updated KAFKA-10454:
--
Fix Version/s: (was: 2.6.0)
> Kafka Streams Stuck in infinite REBALANCING loop whe
[
https://issues.apache.org/jira/browse/KAFKA-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188319#comment-17188319
]
Levani Kokhreidze commented on KAFKA-10454:
---
I guess, in this scenario, Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188313#comment-17188313
]
Levani Kokhreidze edited comment on KAFKA-10454 at 9/1/20, 9:43 AM:
--
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r480997443
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java
##
@@ -203,6 +203,10 @@ public String queryableStore
[
https://issues.apache.org/jira/browse/KAFKA-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188313#comment-17188313
]
Levani Kokhreidze commented on KAFKA-10454:
---
CC [~mjsax] [~vvcephei] [~guozhan
[
https://issues.apache.org/jira/browse/KAFKA-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Levani Kokhreidze updated KAFKA-10454:
--
Description:
Here's integration test: [https://github.com/apache/kafka/pull/9237]
lkokhreidze opened a new pull request #9237:
URL: https://github.com/apache/kafka/pull/9237
Integration test for
[KAFKA-10454](https://github.com/lkokhreidze/kafka/pull/new/KAFKA-10454) bug
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementati
Levani Kokhreidze created KAFKA-10454:
-
Summary: Kafka Streams Stuck in infinite REBALANCING loop when
stream <> table join partitions don't match
Key: KAFKA-10454
URL: https://issues.apache.org/jira/browse/KA
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r480998514
##
File path:
streams/src/test/java/org/apache/kafka/streams/StreamsBuilderTest.java
##
@@ -123,7 +123,7 @@ public void shouldAllowJoinMaterialized
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r480997443
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java
##
@@ -203,6 +203,10 @@ public String queryableStore
[
https://issues.apache.org/jira/browse/KAFKA-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188279#comment-17188279
]
Aakash Gupta commented on KAFKA-3190:
-
[~omkreddy] If no one is working on this, I ca
[
https://issues.apache.org/jira/browse/KAFKA-10072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188254#comment-17188254
]
Ankit Kumar commented on KAFKA-10072:
-
Hey [~qq619618919],
I was trying to replicat
[
https://issues.apache.org/jira/browse/KAFKA-10450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188235#comment-17188235
]
Luke Chen edited comment on KAFKA-10450 at 9/1/20, 7:54 AM:
[
https://issues.apache.org/jira/browse/KAFKA-10450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188235#comment-17188235
]
Luke Chen commented on KAFKA-10450:
---
I think this behavior is expected. The *address a
cnZach opened a new pull request #9236:
URL: https://github.com/apache/kafka/pull/9236
…though we will still retry
Currently, we just capture the exception and retry later, we can't figure
out what happened at runtime, it would be helpful to log a warn message with
details.
*
cadonna commented on a change in pull request #9232:
URL: https://github.com/apache/kafka/pull/9232#discussion_r480927013
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java
##
@@ -174,22 +241,163 @@ private void ini
showuon commented on pull request #9121:
URL: https://github.com/apache/kafka/pull/9121#issuecomment-684518374
@mjsax , I didn't see the Jenkins build results. Should we run again? Thanks.
This is an automated message from th
showuon commented on pull request #9062:
URL: https://github.com/apache/kafka/pull/9062#issuecomment-684518643
@omkreddy , I didn't see the Jenkins build results. Should we run again?
Thanks.
This is an automated message fro
cadonna commented on a change in pull request #9232:
URL: https://github.com/apache/kafka/pull/9232#discussion_r480924297
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java
##
@@ -150,14 +176,55 @@ private void veri
showuon commented on pull request #9202:
URL: https://github.com/apache/kafka/pull/9202#issuecomment-684517819
@ijuma , could you help review this PR again? Thanks.
This is an automated message from the Apache Git Service.
To
cadonna commented on a change in pull request #9232:
URL: https://github.com/apache/kafka/pull/9232#discussion_r480914782
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java
##
@@ -150,14 +176,55 @@ private void veri
cadonna commented on a change in pull request #9232:
URL: https://github.com/apache/kafka/pull/9232#discussion_r480914782
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java
##
@@ -150,14 +176,55 @@ private void veri
91 matches
Mail list logo
