chia7712 commented on a change in pull request #11296:
URL: https://github.com/apache/kafka/pull/11296#discussion_r702636878
##
File path: raft/src/test/java/org/apache/kafka/raft/QuorumStateTest.java
##
@@ -45,7 +44,7 @@
private final MockTime time = new MockTime();
gunnarmorling commented on a change in pull request #11296:
URL: https://github.com/apache/kafka/pull/11296#discussion_r702642533
##
File path: raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java
##
@@ -2799,4 +2779,11 @@ public void testObserverFetchWithNoLocalId
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410256#comment-17410256
]
Tomas Forsman edited comment on KAFKA-13261 at 9/6/21, 7:15 AM:
--
dajac commented on a change in pull request #11295:
URL: https://github.com/apache/kafka/pull/11295#discussion_r702694677
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -354,10 +354,10 @@ object KafkaConfig {
// For ZooKeeper TLS client authenticati
[
https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410473#comment-17410473
]
Sagar Rao commented on KAFKA-8295:
--
Sure thanks [~guozhang]
> Add merge() operator to S
jlprat commented on a change in pull request #11298:
URL: https://github.com/apache/kafka/pull/11298#discussion_r702762251
##
File path: core/src/main/scala/kafka/log/LogCleanerManager.scala
##
@@ -359,9 +359,10 @@ private[log] class LogCleanerManager(val logDirs:
Seq[File],
mimaison opened a new pull request #11299:
URL: https://github.com/apache/kafka/pull/11299
AlterClientQuotas and DescribeProducers have issues when building error
responses. This can lead to brokers returning responses without errors even
when some have happened.
### Committer Chec
cadonna commented on pull request #11241:
URL: https://github.com/apache/kafka/pull/11241#issuecomment-913522749
> As for the user exception task we discussed before, I was trying to create
a ticket but I realized that I could not fully understand the requirement and
ideal outcome of that
sknot-rh edited a comment on pull request #10436:
URL: https://github.com/apache/kafka/pull/10436#issuecomment-91220
I am using this deprecated ctor in my tests. How can I set, for example
`source` option now? The other ctor has a package protected access.
```
ConfigEntry(String n
cadonna merged pull request #11241:
URL: https://github.com/apache/kafka/pull/11241
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr.
[
https://issues.apache.org/jira/browse/KAFKA-13265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ayyandurai Mani updated KAFKA-13265:
Priority: Blocker (was: Critical)
> Kafka consumers disappearing after certain point of t
[
https://issues.apache.org/jira/browse/KAFKA-13265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410574#comment-17410574
]
Ayyandurai Mani commented on KAFKA-13265:
-
We are blocked with this behavior, ex
mimaison opened a new pull request #11300:
URL: https://github.com/apache/kafka/pull/11300
AlterClientQuotas, DescribeProducers and FindCoordinator have issues when
building error responses. This can lead to brokers returning responses without
errors even when some have happened.
mimaison commented on pull request #11299:
URL: https://github.com/apache/kafka/pull/11299#issuecomment-913641292
cc @dajac
--
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 specific comment.
[
https://issues.apache.org/jira/browse/KAFKA-13259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-13259:
---
Description: This is broken since 2.8 but this is directly visible by users
in 3.0 because o
[
https://issues.apache.org/jira/browse/KAFKA-13259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-13259:
---
Priority: Blocker (was: Major)
> DescribeProducers response does not include an error when
mimaison commented on pull request #11300:
URL: https://github.com/apache/kafka/pull/11300#issuecomment-913646455
cc @dajac @kkonstantine
--
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 spe
[
https://issues.apache.org/jira/browse/KAFKA-13259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410601#comment-17410601
]
Mickael Maison commented on KAFKA-13259:
[~kkonstantine] I've tagged this as a b
mimaison commented on pull request #11288:
URL: https://github.com/apache/kafka/pull/11288#issuecomment-913647816
Backports:
- 2.8: https://github.com/apache/kafka/pull/11299
- 3.0: https://github.com/apache/kafka/pull/11300
--
This is an automated message from the Apache Git Servic
ijuma commented on a change in pull request #11296:
URL: https://github.com/apache/kafka/pull/11296#discussion_r702919129
##
File path: raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java
##
@@ -2799,4 +2779,11 @@ public void testObserverFetchWithNoLocalId() throw
ijuma commented on a change in pull request #11296:
URL: https://github.com/apache/kafka/pull/11296#discussion_r702919570
##
File path: raft/src/test/java/org/apache/kafka/raft/MockableRandom.java
##
@@ -0,0 +1,59 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
ijuma commented on a change in pull request #11296:
URL: https://github.com/apache/kafka/pull/11296#discussion_r702921721
##
File path: raft/src/test/java/org/apache/kafka/raft/QuorumStateTest.java
##
@@ -45,7 +44,7 @@
private final MockTime time = new MockTime();
pri
ijuma commented on a change in pull request #11296:
URL: https://github.com/apache/kafka/pull/11296#discussion_r702921946
##
File path: raft/src/test/java/org/apache/kafka/raft/RaftClientTestContext.java
##
@@ -164,7 +162,7 @@ Builder withVotedCandidate(int epoch, int votedId)
chia7712 commented on pull request #10436:
URL: https://github.com/apache/kafka/pull/10436#issuecomment-913671739
> I am using this deprecated ctor in my tests
just curious. Why you need to create `ConfigEntry` in your tests? Could you
share the use case to me? thanks
--
This is a
ijuma commented on a change in pull request #11295:
URL: https://github.com/apache/kafka/pull/11295#discussion_r702924352
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -354,10 +354,10 @@ object KafkaConfig {
// For ZooKeeper TLS client authenticati
sknot-rh commented on pull request #10436:
URL: https://github.com/apache/kafka/pull/10436#issuecomment-913679136
The test scenario is basically "mocking" server response to
`describeConfig`. Then I am looking at the `source` property to determine
whether the changed configuration property
ijuma commented on a change in pull request #11295:
URL: https://github.com/apache/kafka/pull/11295#discussion_r702929731
##
File path: core/src/test/scala/unit/kafka/zk/KafkaZkClientTest.scala
##
@@ -1340,6 +1343,32 @@ class KafkaZkClientTest extends ZooKeeperTestHarness {
ijuma commented on pull request #11295:
URL: https://github.com/apache/kafka/pull/11295#issuecomment-913681527
@dajac Thanks for the review, I pushed a commit that addresses your feedback.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
chia7712 commented on pull request #10436:
URL: https://github.com/apache/kafka/pull/10436#issuecomment-913687917
> The test scenario is basically "mocking" server response to describeConfig.
Do you create a mock kafka admin and then mock response for specify request.
If so, it seems
sknot-rh commented on pull request #10436:
URL: https://github.com/apache/kafka/pull/10436#issuecomment-913689790
No, it is just a junit test consuming properties in `key=value` format. And
I want to mark init configuration as default.
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17409883#comment-17409883
]
Tomas Forsman edited comment on KAFKA-13261 at 9/6/21, 2:26 PM:
--
chia7712 commented on pull request #10436:
URL: https://github.com/apache/kafka/pull/10436#issuecomment-913701007
ok. How about using reflection to update private fields of `ConfigEntry`?
For example:
```java
Class clazz = ConfigEntry.class;
ConfigEntry entry =
sknot-rh commented on pull request #10436:
URL: https://github.com/apache/kafka/pull/10436#issuecomment-913702209
Yes, I used seemthing similar. Thank you for looking :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410650#comment-17410650
]
Tomas Forsman commented on KAFKA-13261:
---
I think I need some help to verify if tha
sknot-rh edited a comment on pull request #10436:
URL: https://github.com/apache/kafka/pull/10436#issuecomment-913702209
Yes, I used something similar. Thank you for looking :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
ijuma commented on pull request #10436:
URL: https://github.com/apache/kafka/pull/10436#issuecomment-913705180
I think it makes sense to make the constructor public, but it would require
a small kip. We don't gain anything by not making it public if people access it
via reflection anyway.
sknot-rh commented on pull request #10436:
URL: https://github.com/apache/kafka/pull/10436#issuecomment-913710299
Let me know if I can do my first contribution! :laughing:
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
tombentley commented on pull request #10436:
URL: https://github.com/apache/kafka/pull/10436#issuecomment-913714434
[KIP-692](https://cwiki.apache.org/confluence/display/KAFKA/KIP-692:+Make+AdminClient+value+object+constructors+public)
proposed to do this for all the record-like classes in
ijuma commented on pull request #10436:
URL: https://github.com/apache/kafka/pull/10436#issuecomment-913715227
@tombentley maybe we should vote for it then :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
ijuma commented on pull request #11017:
URL: https://github.com/apache/kafka/pull/11017#issuecomment-913720572
@wycc Can you please fix the conflict? @chia7712 How do you feel about
this PR, is it close to being ready to be merged?
--
This is an automated message from the Apache Git
ijuma merged pull request #11051:
URL: https://github.com/apache/kafka/pull/11051
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr...
ijuma merged pull request #11027:
URL: https://github.com/apache/kafka/pull/11027
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr...
ijuma commented on pull request #10976:
URL: https://github.com/apache/kafka/pull/10976#issuecomment-913726974
@wycc Is this ready for another round of reviews from @chia7712 ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
ijuma commented on pull request #10881:
URL: https://github.com/apache/kafka/pull/10881#issuecomment-913727723
@wycc Are you planning to address the outstanding review comments?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
ijuma commented on a change in pull request #10904:
URL: https://github.com/apache/kafka/pull/10904#discussion_r702976716
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMemberTest.java
##
@@ -86,18 +83,12 @@ public void test
dajac commented on a change in pull request #11299:
URL: https://github.com/apache/kafka/pull/11299#discussion_r702978011
##
File path:
clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java
##
@@ -657,6 +657,11 @@ private void checkDescribeConfigsResp
mimaison commented on a change in pull request #11299:
URL: https://github.com/apache/kafka/pull/11299#discussion_r702982585
##
File path:
clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java
##
@@ -657,6 +657,11 @@ private void checkDescribeConfigsR
ijuma merged pull request #11296:
URL: https://github.com/apache/kafka/pull/11296
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr...
chia7712 commented on a change in pull request #10976:
URL: https://github.com/apache/kafka/pull/10976#discussion_r702987181
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorderTest.java
##
@@ -70,99 +63,90 @@
private
chia7712 commented on pull request #11017:
URL: https://github.com/apache/kafka/pull/11017#issuecomment-913747482
> How do you feel about this PR, is it close to being ready to be merged?
I need to take another look after those conflicts are fixed.
--
This is an automated message f
ijuma commented on a change in pull request #11024:
URL: https://github.com/apache/kafka/pull/11024#discussion_r702993808
##
File path:
connect/basic-auth-extension/src/test/java/org/apache/kafka/connect/rest/basic/auth/extension/BasicAuthSecurityRestExtensionTest.java
##
@@ -
Tom Bentley created KAFKA-13276:
---
Summary: Public DescribeConsumerGroupsResult constructor refers to
KafkaFutureImpl
Key: KAFKA-13276
URL: https://issues.apache.org/jira/browse/KAFKA-13276
Project: Kafk
ijuma merged pull request #11295:
URL: https://github.com/apache/kafka/pull/11295
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr...
[
https://issues.apache.org/jira/browse/KAFKA-13270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-13270.
-
Assignee: Ismael Juma (was: Ron Dagostino)
Resolution: Fixed
> Kafka may fail to connect
ijuma commented on a change in pull request #11074:
URL: https://github.com/apache/kafka/pull/11074#discussion_r702994755
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/RestServerTest.java
##
@@ -61,18 +56,23 @@
import static org.junit.Asser
[
https://issues.apache.org/jira/browse/KAFKA-13101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-13101:
Fix Version/s: 3.1.0
> Replace EasyMock and PowerMock with Mockito for RestServerTest
> --
ijuma commented on pull request #11137:
URL: https://github.com/apache/kafka/pull/11137#issuecomment-913758905
@kkonstantine @rhauch It would be great to have a review from one of you two
so that we can get this merged.
--
This is an automated message from the Apache Git Service.
To resp
ijuma commented on a change in pull request #11137:
URL: https://github.com/apache/kafka/pull/11137#discussion_r703001846
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractHerderTest.java
##
@@ -135,90 +133,75 @@
private final int genera
ijuma commented on pull request #11137:
URL: https://github.com/apache/kafka/pull/11137#issuecomment-913759692
We should also remove this test from
https://github.com/apache/kafka/blob/trunk/build.gradle#L381 before we merge
this PR.
--
This is an automated message from the Apache Git S
tombentley commented on pull request #11301:
URL: https://github.com/apache/kafka/pull/11301#issuecomment-913760134
@dajac @mimaison @ijuma perhaps one of you could review?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
ijuma commented on a change in pull request #11301:
URL: https://github.com/apache/kafka/pull/11301#discussion_r703003174
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConsumerGroupsResult.java
##
@@ -35,9 +34,9 @@
@InterfaceStability.Evolving
pu
tombentley commented on a change in pull request #11301:
URL: https://github.com/apache/kafka/pull/11301#discussion_r703010447
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConsumerGroupsResult.java
##
@@ -35,9 +34,9 @@
@InterfaceStability.Evolvin
ijuma commented on a change in pull request #11301:
URL: https://github.com/apache/kafka/pull/11301#discussion_r703013390
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConsumerGroupsResult.java
##
@@ -35,9 +34,9 @@
@InterfaceStability.Evolving
pu
tombentley commented on a change in pull request #11301:
URL: https://github.com/apache/kafka/pull/11301#discussion_r703018601
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConsumerGroupsResult.java
##
@@ -35,9 +34,9 @@
@InterfaceStability.Evolvin
wycc commented on pull request #11017:
URL: https://github.com/apache/kafka/pull/11017#issuecomment-913789041
@chia7712 The conflict has been resolved, let me know if you have any
situation.
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
ijuma commented on pull request #11017:
URL: https://github.com/apache/kafka/pull/11017#issuecomment-913789472
Btw, this is the only Streams test that is disabled with Java 16 and newer:
https://github.com/apache/kafka/blob/trunk/build.gradle#L389
--
This is an automated message from t
ijuma commented on a change in pull request #11017:
URL: https://github.com/apache/kafka/pull/11017#discussion_r703026597
##
File path: streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
##
@@ -111,9 +104,24 @@
import static org.junit.Assert.assertThrows;
im
ijuma commented on a change in pull request #11017:
URL: https://github.com/apache/kafka/pull/11017#discussion_r703026597
##
File path: streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
##
@@ -111,9 +104,24 @@
import static org.junit.Assert.assertThrows;
im
dajac commented on a change in pull request #11301:
URL: https://github.com/apache/kafka/pull/11301#discussion_r703030864
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupsResult.java
##
@@ -32,9 +31,9 @@
*/
@InterfaceStability.Evolving
dajac commented on a change in pull request #11299:
URL: https://github.com/apache/kafka/pull/11299#discussion_r703031302
##
File path:
clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java
##
@@ -657,6 +657,11 @@ private void checkDescribeConfigsResp
wycc commented on a change in pull request #11137:
URL: https://github.com/apache/kafka/pull/11137#discussion_r703032964
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractHerderTest.java
##
@@ -135,90 +133,75 @@
private final int gen
ijuma commented on pull request #11074:
URL: https://github.com/apache/kafka/pull/11074#issuecomment-913801179
Tests passed for JDK 8, 11 and 17. Merging to master.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
ijuma merged pull request #11074:
URL: https://github.com/apache/kafka/pull/11074
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr...
ijuma commented on pull request #11074:
URL: https://github.com/apache/kafka/pull/11074#issuecomment-913801648
cc @rhauch @kkonstantine
--
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 speci
ijuma commented on pull request #11027:
URL: https://github.com/apache/kafka/pull/11027#issuecomment-913801895
cc @kkonstantine @rhauch
--
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 speci
ijuma commented on pull request #11051:
URL: https://github.com/apache/kafka/pull/11051#issuecomment-913801988
cc @rhauch @kkonstantine
--
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 speci
[
https://issues.apache.org/jira/browse/KAFKA-8116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410761#comment-17410761
]
Ismael Juma commented on KAFKA-8116:
Java 8 support has been deprecated in 3.0 and wi
jlprat opened a new pull request #11302:
URL: https://github.com/apache/kafka/pull/11302
Implementation of [KIP-773](https://cwiki.apache.org/confluence/x/ZwNACw)
- Deprecates inconsistent metrics `bufferpool-wait-time-total`,
`io-waittime-total`, and `iotime-total`.
- Introduces
jlprat commented on a change in pull request #11302:
URL: https://github.com/apache/kafka/pull/11302#discussion_r703047638
##
File path: clients/src/main/java/org/apache/kafka/common/network/Selector.java
##
@@ -1272,12 +1274,27 @@ private Meter createMeter(Metrics metrics, Str
ijuma commented on pull request #11289:
URL: https://github.com/apache/kafka/pull/11289#issuecomment-913838350
@hachikuji Thanks for the PR. Can we please also mention the change that
introduced this?
--
This is an automated message from the Apache Git Service.
To respond to the message,
jlprat commented on pull request #11302:
URL: https://github.com/apache/kafka/pull/11302#issuecomment-913863510
Failure was:
```
[2021-09-06T19ː26ː29.273Z] FAILURE: Build failed with an exception.
[2021-09-06T19ː26ː29.273Z] [2021-09-06T19ː26ː29.273Z] * What went wrong:
[2021-09-0
jlprat edited a comment on pull request #11302:
URL: https://github.com/apache/kafka/pull/11302#issuecomment-913863510
Failure was:
```
[2021-09-06T19ː26ː29.273Z] FAILURE: Build failed with an exception.
[2021-09-06T19ː26ː29.273Z]
[2021-09-06T19ː26ː29.273Z] * What went wrong:
jlprat commented on pull request #11302:
URL: https://github.com/apache/kafka/pull/11302#issuecomment-913864416
@guozhangwang @cadonna and @tombentley if you want and have time, feel free
to review the PR for KIP-773
Thanks!
--
This is an automated message from the Apache Git Service
[
https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410827#comment-17410827
]
Adam Bellemare commented on KAFKA-13261:
Hi [~xnix] - Thank you for the test cod
showuon commented on pull request #11147:
URL: https://github.com/apache/kafka/pull/11147#issuecomment-913896267
@ijuma , please help take a look at the follow up PR to add tests. Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
ijuma opened a new pull request #11303:
URL: https://github.com/apache/kafka/pull/11303
lz4-java: 1.7.1 -> 1.8.0
The most noteworthy change is the upgrade of the
underlying C library to 1.9.3. Details:
* https://github.com/lz4/lz4-java/releases/tag/1.8.0
* https://github.
yangdaixai opened a new pull request #11304:
URL: https://github.com/apache/kafka/pull/11304
…tsException,When a topic is marked for deletion.
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separa
yangdaixai commented on pull request #11226:
URL: https://github.com/apache/kafka/pull/11226#issuecomment-914008135
> 通常，我们应该包括对此类更改的测试。
Supplement unit test for KAFKA-13175:
https://github.com/apache/kafka/pull/11304
@ijuma @guozhangwang
--
This is an automated message from
yangdaixai commented on pull request #11304:
URL: https://github.com/apache/kafka/pull/11304#issuecomment-914008453
@ijuma @guozhangwang
Supplement unit test for KAFKA-13175.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
jlprat commented on pull request #11303:
URL: https://github.com/apache/kafka/pull/11303#issuecomment-914028927
I had the same error on another PR yesterday. Might be a Gradle build
instance turned into a zombie on a Jenkins worker.
> I saw there's a build error:
> ```
> * Wha
showuon commented on a change in pull request #11301:
URL: https://github.com/apache/kafka/pull/11301#discussion_r703229535
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiFuture.java
##
@@ -109,7 +110,7 @@ private void completeExceptionall
showuon commented on a change in pull request #11301:
URL: https://github.com/apache/kafka/pull/11301#discussion_r703230627
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupsResult.java
##
@@ -32,9 +31,9 @@
*/
@InterfaceStability.Evolvin
92 matches
Mail list logo
