chia7712 commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-683602732
@junrao the result of ```benchmark_test.py``` is attached (see description)
The main regression ({"records_per_sec": 3653635.3672, "mb_per_sec":
348.4378} -> {"records_per_
cadonna commented on pull request #9177:
URL: https://github.com/apache/kafka/pull/9177#issuecomment-683631452
@vvcephei Thank you very much for taking care of the conflicts and merging
the PR!
This is an automated message f
cadonna commented on pull request #9191:
URL: https://github.com/apache/kafka/pull/9191#issuecomment-683673488
This is the implementation for KIP-662.
This is an automated message from the Apache Git Service.
To respond to th
ijuma commented on a change in pull request #9231:
URL: https://github.com/apache/kafka/pull/9231#discussion_r480023644
##
File path:
tools/src/test/java/org/apache/kafka/trogdor/coordinator/CoordinatorTest.java
##
@@ -62,17 +62,18 @@
import java.util.List;
import java.util.
cadonna opened a new pull request #9232:
URL: https://github.com/apache/kafka/pull/9232
This commit adds the remaining property-based RocksDB metrics as described
in KIP-607, except for num-entries-active-mem-table, which was added in PR
#9177.
### Committer Checklist (excluded from
cadonna commented on pull request #9232:
URL: https://github.com/apache/kafka/pull/9232#issuecomment-683729711
Call for review: @guozhangwang @vvcephei
This is an automated message from the Apache Git Service.
To respond to
rondagostino opened a new pull request #9233:
URL: https://github.com/apache/kafka/pull/9233
*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 test
rondagostino closed pull request #9233:
URL: https://github.com/apache/kafka/pull/9233
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-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187747#comment-17187747
]
Sören Henning commented on KAFKA-9649:
--
Hi, sorry for the late response, vacation ca
[
https://issues.apache.org/jira/browse/KAFKA-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187747#comment-17187747
]
Sören Henning edited comment on KAFKA-9649 at 8/31/20, 1:49 PM:
---
jeqo commented on pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#issuecomment-683830757
@ableegoldman key ordering is added to `InMemoryWindowStore` now
This is an automated message from the Apache Git Ser
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r480194412
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,386 @@
+/*
+ * Licensed to th
junrao commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-683859366
@chia7712 : Thanks for the performance results. It seems that the average
across multiple runs doesn't change much?
Also, 1 failure in the latest system test run.
http://
[
https://issues.apache.org/jira/browse/KAFKA-10448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10448:
Labels: needs-kip (was: )
> Preserve Source Partition in Kafka Streams from context
> ---
chia7712 commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-683863356
> It seems that the average across multiple runs doesn't change much?
yep. I didn't observe obvious regression caused by this patch.
> Also, 1 failure in the latest s
[
https://issues.apache.org/jira/browse/KAFKA-10448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10448:
Priority: Minor (was: Critical)
> Preserve Source Partition in Kafka Streams from context
Jigar Naik created KAFKA-10450:
--
Summary: console-producer throws Uncaught error in kafka producer
I/O thread: (org.apache.kafka.clients.producer.internals.Sender)
java.lang.IllegalStateException: There are no in-flight requests for node -1
[
https://issues.apache.org/jira/browse/KAFKA-10450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jigar Naik updated KAFKA-10450:
---
Priority: Blocker (was: Major)
> console-producer throws Uncaught error in kafka producer I/O threa
[
https://issues.apache.org/jira/browse/KAFKA-10450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jigar Naik updated KAFKA-10450:
---
Priority: Critical (was: Blocker)
> console-producer throws Uncaught error in kafka producer I/O th
[
https://issues.apache.org/jira/browse/KAFKA-10450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jigar Naik updated KAFKA-10450:
---
Priority: Blocker (was: Critical)
> console-producer throws Uncaught error in kafka producer I/O th
asdaraujo commented on a change in pull request #8730:
URL: https://github.com/apache/kafka/pull/8730#discussion_r480265451
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -367,14 +406,37 @@ public void test
asdaraujo commented on a change in pull request #8730:
URL: https://github.com/apache/kafka/pull/8730#discussion_r480266459
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -128,10 +136,23 @@ public void setu
asdaraujo commented on a change in pull request #8730:
URL: https://github.com/apache/kafka/pull/8730#discussion_r480267122
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -128,10 +136,23 @@ public void setu
asdaraujo commented on a change in pull request #8730:
URL: https://github.com/apache/kafka/pull/8730#discussion_r480267347
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -190,24 +211,19 @@ public void clos
asdaraujo commented on pull request #8730:
URL: https://github.com/apache/kafka/pull/8730#issuecomment-683909598
@mimaison Thanks for the feedback. I've refactored the tests. Could you
please give it another review.
This is
Ron Dagostino created KAFKA-10451:
-
Summary: system tests send large command over ssh instead of using
remote file for security config
Key: KAFKA-10451
URL: https://issues.apache.org/jira/browse/KAFKA-10451
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r480272048
##
File path: tests/kafkatest/services/kafka/kafka.py
##
@@ -575,10 +577,21 @@ def set_unclean_leader_election(self, topic, value=True,
node=None):
ableegoldman commented on pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#issuecomment-683916587
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
ableegoldman commented on pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#issuecomment-683917229
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, pleas
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r480282139
##
File path: core/src/test/scala/unit/kafka/utils/JaasTestUtils.scala
##
@@ -169,6 +169,18 @@ object JaasTestUtils {
jaasFile
}
+ // Return
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r480301973
##
File path:
core/src/test/scala/unit/kafka/admin/UserScramCredentialsCommandTest.scala
##
@@ -0,0 +1,135 @@
+/**
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/KAFKA-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-9649:
---
Labels: kip (was: )
> Remove/Warn on use of TimeWindowedSerde with no specified window size
[
https://issues.apache.org/jira/browse/KAFKA-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-9649:
--
Assignee: Leah Thomas
> Remove/Warn on use of TimeWindowedSerde with no specified wind
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r480324560
##
File path:
core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala
##
@@ -1047,8 +1047,8 @@ class DynamicBrokerReconfig
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r480329570
##
File path:
core/src/test/scala/integration/kafka/api/SaslScramSslEndToEndAuthorizationTest.scala
##
@@ -42,7 +42,18 @@ class SaslScramSslEndToEndAu
[
https://issues.apache.org/jira/browse/KAFKA-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-10384.
--
Fix Version/s: 2.7.0
Resolution: Fixed
> Separate converters from generated messages
>
[
https://issues.apache.org/jira/browse/KAFKA-10434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10434:
-
Fix Version/s: 3.0.0
> Remove deprecated methods on WindowStore
> --
[
https://issues.apache.org/jira/browse/KAFKA-10434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10434:
-
Priority: Blocker (was: Major)
> Remove deprecated methods on WindowStore
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-10445:
Assignee: Jorge Esteban Quilcate Otoya
> Align IQ SessionStore API with Instant-based met
[
https://issues.apache.org/jira/browse/KAFKA-10434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187962#comment-17187962
]
John Roesler commented on KAFKA-10434:
--
Marked as a 3.0 blocker so we will be sure
[
https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10417:
-
Fix Version/s: 2.6.1
> suppress() with cogroup() throws ClassCastException
> ---
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r480370634
##
File path:
core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala
##
@@ -545,6 +558,16 @@ abstract class EndToEndAuthorizationTe
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r480370463
##
File path:
core/src/test/scala/integration/kafka/api/SaslClientsWithInvalidCredentialsTest.scala
##
@@ -248,4 +250,25 @@ class SaslClientsWithInval
[
https://issues.apache.org/jira/browse/KAFKA-10429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187992#comment-17187992
]
John Roesler commented on KAFKA-10429:
--
Hi Navinder,
My first thought is that vers
Jeff Kim created KAFKA-10452:
Summary: Only expire preferred read replica if a leader is alive
for the topic
Key: KAFKA-10452
URL: https://issues.apache.org/jira/browse/KAFKA-10452
Project: Kafka
ijuma commented on a change in pull request #9226:
URL: https://github.com/apache/kafka/pull/9226#discussion_r480364696
##
File path: Jenkinsfile
##
@@ -0,0 +1,200 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreem
mumrah commented on a change in pull request #9226:
URL: https://github.com/apache/kafka/pull/9226#discussion_r480388916
##
File path: Jenkinsfile
##
@@ -0,0 +1,200 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agree
mumrah commented on a change in pull request #9226:
URL: https://github.com/apache/kafka/pull/9226#discussion_r480391239
##
File path: Jenkinsfile
##
@@ -0,0 +1,200 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agree
lbradstreet commented on a change in pull request #9226:
URL: https://github.com/apache/kafka/pull/9226#discussion_r480392178
##
File path: Jenkinsfile
##
@@ -0,0 +1,200 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license
[
https://issues.apache.org/jira/browse/KAFKA-10452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-10452:
-
Description:
Fetch from follower functionality periodically expires and refreshes preferred
read replic
mumrah commented on a change in pull request #9226:
URL: https://github.com/apache/kafka/pull/9226#discussion_r480393840
##
File path: Jenkinsfile
##
@@ -0,0 +1,200 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agree
vvcephei opened a new pull request #9234:
URL: https://github.com/apache/kafka/pull/9234
Record the `pollSensor` after every invocation to poll, rather than just
when we get records back so that we can accurately gauge how often we're
invoking Consumer#poll.
### Committer Checklist
vvcephei commented on pull request #9234:
URL: https://github.com/apache/kafka/pull/9234#issuecomment-684038074
Hey @guozhangwang and @cadonna , I was just looking into key metrics for
monitoring, and it seems like this metric is misplaced. Unlike the
`pollRecordsSensor`, it seems like the
lbradstreet commented on a change in pull request #9226:
URL: https://github.com/apache/kafka/pull/9226#discussion_r480404009
##
File path: Jenkinsfile
##
@@ -0,0 +1,200 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r480407445
##
File path:
core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala
##
@@ -545,6 +558,16 @@ abstract class EndToEndAuthorizationTe
Niketh Sabbineni created KAFKA-10453:
Summary: Backport of PR-7781
Key: KAFKA-10453
URL: https://issues.apache.org/jira/browse/KAFKA-10453
Project: Kafka
Issue Type: Wish
Compon
[
https://issues.apache.org/jira/browse/KAFKA-10453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188017#comment-17188017
]
Ismael Juma commented on KAFKA-10453:
-
Can you help us understand why would it be mu
[
https://issues.apache.org/jira/browse/KAFKA-10453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188020#comment-17188020
]
Niketh Sabbineni commented on KAFKA-10453:
--
We are running on an older version
[
https://issues.apache.org/jira/browse/KAFKA-10453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188021#comment-17188021
]
Niketh Sabbineni commented on KAFKA-10453:
--
IMO |[https://github.com/apache/kaf
tinawenqiao opened a new pull request #9235:
URL: https://github.com/apache/kafka/pull/9235
…rties.
*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.*
*S
tinawenqiao commented on pull request #9235:
URL: https://github.com/apache/kafka/pull/9235#issuecomment-684064832
In WokerConfig.java we found that REST_HOST_NAME_CONFIG(rest.host.name) and
REST_PORT_CONFIG(rest.port) were deprecated. And some new configuration
parameters are introduced s
[
https://issues.apache.org/jira/browse/KAFKA-10453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188024#comment-17188024
]
Ismael Juma commented on KAFKA-10453:
-
Kafka clients have no ZK dependency, so you c
[
https://issues.apache.org/jira/browse/KAFKA-10453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188028#comment-17188028
]
Niketh Sabbineni commented on KAFKA-10453:
--
[~ijuma] Thanks for your reply. Do
[
https://issues.apache.org/jira/browse/KAFKA-10453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188028#comment-17188028
]
Niketh Sabbineni edited comment on KAFKA-10453 at 8/31/20, 10:07 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-10453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188031#comment-17188031
]
Niketh Sabbineni commented on KAFKA-10453:
--
Thank you! Let me test that out the
guozhangwang commented on a change in pull request #8834:
URL: https://github.com/apache/kafka/pull/8834#discussion_r476954744
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -917,17 +938,14 @@ private synchronized
[
https://issues.apache.org/jira/browse/KAFKA-10453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188029#comment-17188029
]
Ismael Juma commented on KAFKA-10453:
-
Yes, it is.
> Backport of PR-7781
>
guozhangwang commented on a change in pull request #8834:
URL: https://github.com/apache/kafka/pull/8834#discussion_r480425820
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -497,40 +501,18 @@ private synchronized
vvcephei commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r480429410
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,391 @@
+/*
+ * Licensed to
guozhangwang commented on a change in pull request #8834:
URL: https://github.com/apache/kafka/pull/8834#discussion_r480429496
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -528,7 +528,6 @@ public void onFailure(
vvcephei merged pull request #9039:
URL: https://github.com/apache/kafka/pull/9039
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 pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#issuecomment-684074223
Since Jenkins PR builds are still not functioning, I've merged in trunk and
verified this pull request locally before merging it.
---
mumrah commented on a change in pull request #9226:
URL: https://github.com/apache/kafka/pull/9226#discussion_r480452574
##
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-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188042#comment-17188042
]
Aakash Gupta commented on KAFKA-2200:
-
Hi [~becket_qin]
I am willing to take this ti
[
https://issues.apache.org/jira/browse/KAFKA-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aakash Gupta reassigned KAFKA-2200:
---
Assignee: Aakash Gupta
> kafkaProducer.send() should not call callback.onCompletion()
>
[
https://issues.apache.org/jira/browse/KAFKA-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188042#comment-17188042
]
Aakash Gupta edited comment on KAFKA-2200 at 8/31/20, 11:20 PM:
---
guozhangwang commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r480469688
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java
##
@@ -136,34 +174,64 @@
*
* This iterator mu
guozhangwang commented on a change in pull request #9232:
URL: https://github.com/apache/kafka/pull/9232#discussion_r480477639
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java
##
@@ -150,14 +176,55 @@ private void
ableegoldman commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r480479677
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java
##
@@ -271,27 +345,68 @@ public synchronized void
ableegoldman commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r480481060
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java
##
@@ -338,25 +452,36 @@ public synchronized void
ableegoldman commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r480482350
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentIterator.java
##
@@ -67,14 +70,22 @@ public Bytes peekNextKey() {
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188058#comment-17188058
]
Jerry Wei commented on KAFKA-10134:
---
[~guozhang] one more question about PR #8834, whe
[
https://issues.apache.org/jira/browse/KAFKA-10450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188082#comment-17188082
]
huxihx commented on KAFKA-10450:
Same version for both clients and brokers?
> console-p
[
https://issues.apache.org/jira/browse/KAFKA-10450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jigar Naik updated KAFKA-10450:
---
Priority: Critical (was: Blocker)
> console-producer throws Uncaught error in kafka producer I/O th
[
https://issues.apache.org/jira/browse/KAFKA-10450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188085#comment-17188085
]
Jigar Naik commented on KAFKA-10450:
Yes, same version for both. And also from kafka
[
https://issues.apache.org/jira/browse/KAFKA-10450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jigar Naik updated KAFKA-10450:
---
Priority: Minor (was: Critical)
> console-producer throws Uncaught error in kafka producer I/O thre
mumrah commented on pull request #9226:
URL: https://github.com/apache/kafka/pull/9226#issuecomment-684175203
Example failed build with a compile error:
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/view/change-requests/job/PR-9226/67
One with a rat failure:
https://ci-builds.
[
https://issues.apache.org/jira/browse/KAFKA-10366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188115#comment-17188115
]
Sophie Blee-Goldman commented on KAFKA-10366:
-
Yeah thanks for tracking that
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188116#comment-17188116
]
Guozhang Wang commented on KAFKA-10134:
---
Hello [~zhowei] that broker-side change i
[
https://issues.apache.org/jira/browse/KAFKA-10072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankit Kumar reassigned KAFKA-10072:
---
Assignee: Ankit Kumar
> Kafkaconsumer is configured with different clientid parameters to o
[
https://issues.apache.org/jira/browse/KAFKA-10453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niketh Sabbineni resolved KAFKA-10453.
--
Resolution: Workaround
> Backport of PR-7781
> ---
>
>
91 matches
Mail list logo
