abbccdda commented on a change in pull request #9815:
URL: https://github.com/apache/kafka/pull/9815#discussion_r553162016
##
File path: examples/src/main/java/kafka/examples/Consumer.java
##
@@ -26,33 +25,34 @@
import java.util.Collections;
import java.util.Optional;
import
showuon commented on pull request #9777:
URL: https://github.com/apache/kafka/pull/9777#issuecomment-755973862
@rajinisivaram , please help review this PR. Thanks.
This is an automated message from the Apache Git Service.
To
dajac merged pull request #9778:
URL: https://github.com/apache/kafka/pull/9778
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-10874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-10874.
-
Fix Version/s: 2.8.0
Resolution: Fixed
> Fix flaky ClientQuotasRequestTest.testAlterIpQuo
Tom Bentley created KAFKA-12156:
---
Summary: Document consequences of single threaded response handling
Key: KAFKA-12156
URL: https://issues.apache.org/jira/browse/KAFKA-12156
Project: Kafka
Issu
tombentley opened a new pull request #9842:
URL: https://github.com/apache/kafka/pull/9842
As described in
[KAFKA-12156](https://issues.apache.org/jira/browse/KAFKA-12156), if users
block the response handling thread in one call waiting for the result of a
second "nested" call then the cl
tombentley commented on pull request #9842:
URL: https://github.com/apache/kafka/pull/9842#issuecomment-756017569
@chia7712 please could you review?
This is an automated message from the Apache Git Service.
To respond to the
Wenbing Shen created KAFKA-12157:
Summary: test Upgrade 2.7.0 from 2.0.0 occur a question
Key: KAFKA-12157
URL: https://issues.apache.org/jira/browse/KAFKA-12157
Project: Kafka
Issue Type: Bu
chia7712 commented on pull request #9842:
URL: https://github.com/apache/kafka/pull/9842#issuecomment-756041450
This is similar to #9707
The document is good but throwing a exception to break deadlock is more
meaningful for me. Users can read the error message straightforward. WDYT?
dajac commented on pull request #9827:
URL: https://github.com/apache/kafka/pull/9827#issuecomment-756041472
@chia7712 Thanks for your comments. I have addressed them. Could you take
another look at the PR?
This is an automa
omkreddy closed pull request #9841:
URL: https://github.com/apache/kafka/pull/9841
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
chia7712 commented on pull request #9707:
URL: https://github.com/apache/kafka/pull/9707#issuecomment-756071279
Personally, the callback is a bit weird to me. The callback mechanism makes
“internal” thread to handle user-defined code. The user code to handle
response/error is vary differen
dengziming commented on pull request #9807:
URL: https://github.com/apache/kafka/pull/9807#issuecomment-756104663
@hachikuji , Thank you for your reminder, currently, the method only test
the basic logic, maybe it's uneasy to cover all edge cases of reassignment. I
added a few cases consid
dongjinleekr commented on a change in pull request #9420:
URL: https://github.com/apache/kafka/pull/9420#discussion_r553355399
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##
@@ -602,7 +603,7 @@
REPLICATION_FACTOR_DOC)
chia7712 commented on pull request #9837:
URL: https://github.com/apache/kafka/pull/9837#issuecomment-756148992
Is there a incorrect jira number? I can't get the relation between this PR
and KAFKA-6566.
This is an automated
ijuma commented on a change in pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#discussion_r553369873
##
File path: core/src/test/scala/unit/kafka/zookeeper/ZooKeeperClientTest.scala
##
@@ -715,7 +711,7 @@ class ZooKeeperClientTest extends ZooKeeperTestHarness
chia7712 commented on a change in pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#discussion_r553386104
##
File path: core/src/test/scala/unit/kafka/zookeeper/ZooKeeperClientTest.scala
##
@@ -715,7 +711,7 @@ class ZooKeeperClientTest extends ZooKeeperTestHarn
chia7712 commented on a change in pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#discussion_r553390132
##
File path: core/src/test/scala/integration/kafka/api/TransactionsTest.scala
##
@@ -407,46 +406,40 @@ class TransactionsTest extends KafkaServerTestHarne
chia7712 commented on a change in pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#discussion_r553392601
##
File path: core/src/test/scala/unit/kafka/utils/QuotaUtilsTest.scala
##
@@ -17,24 +17,21 @@
package kafka.utils
-import java.util.concurrent.TimeUn
chia7712 commented on a change in pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#discussion_r553394406
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorNodeTest.java
##
@@ -49,18 +49,17 @@
public class ProcessorNode
chia7712 opened a new pull request #9843:
URL: https://github.com/apache/kafka/pull/9843
**before**
```
Timeout expired after 1000milliseconds while awaiting InitProducerId
```
**after**
```
Timeout expired after 1000 milliseconds while awaiting InitProducerId
```
cadonna commented on a change in pull request #9695:
URL: https://github.com/apache/kafka/pull/9695#discussion_r553380512
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -947,24 +948,65 @@ private StreamThread createStreamThread(final long
[
https://issues.apache.org/jira/browse/KAFKA-12156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley updated KAFKA-12156:
Description:
If users block the response handling thread in one call waiting for the result
of a
ijuma commented on a change in pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#discussion_r553388205
##
File path: core/src/test/scala/unit/kafka/server/DynamicBrokerConfigTest.scala
##
@@ -343,7 +340,7 @@ class DynamicBrokerConfigTest {
class TestAuth
ijuma commented on a change in pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#discussion_r553437304
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorNodeTest.java
##
@@ -49,18 +49,17 @@
public class ProcessorNodeTes
ijuma commented on a change in pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#discussion_r553437994
##
File path: core/src/test/scala/unit/kafka/utils/QuotaUtilsTest.scala
##
@@ -17,24 +17,21 @@
package kafka.utils
-import java.util.concurrent.TimeUnit
chia7712 commented on a change in pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#discussion_r553439047
##
File path: core/src/test/scala/unit/kafka/utils/QuotaUtilsTest.scala
##
@@ -17,24 +17,21 @@
package kafka.utils
-import java.util.concurrent.TimeUn
vamossagar12 commented on a change in pull request #9756:
URL: https://github.com/apache/kafka/pull/9756#discussion_r553472551
##
File path:
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java
##
@@ -37,6 +37,7 @@
private final Time time;
private
vamossagar12 commented on a change in pull request #9756:
URL: https://github.com/apache/kafka/pull/9756#discussion_r553481214
##
File path:
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java
##
@@ -211,6 +214,33 @@ public long timeUntilDrain(long current
vamossagar12 commented on a change in pull request #9508:
URL: https://github.com/apache/kafka/pull/9508#discussion_r553483419
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBPrefixIterator.java
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Ap
vamossagar12 commented on a change in pull request #9717:
URL: https://github.com/apache/kafka/pull/9717#discussion_r553484121
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBRangeIteratorTest.java
##
@@ -0,0 +1,295 @@
+/*
+ * Licensed to th
vamossagar12 commented on pull request #9779:
URL: https://github.com/apache/kafka/pull/9779#issuecomment-756273125
@cadonna , could you plz review this PR whenever you get the chance? Thanks!
This is an automated message fro
wcarlson5 commented on a change in pull request #9695:
URL: https://github.com/apache/kafka/pull/9695#discussion_r553490127
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -1432,7 +1480,9 @@ public void cleanUp() {
validateIsRunning
chia7712 commented on pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#issuecomment-756282441
I have reverted most unrelated changes. see
https://github.com/apache/kafka/pull/9520/commits/d0e2236e96db0b514f4d2c07641eb236feb1de74
-
mimaison opened a new pull request #9844:
URL: https://github.com/apache/kafka/pull/9844
Waiting for artifacts to appear in maven before merging
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build
hachikuji commented on a change in pull request #9838:
URL: https://github.com/apache/kafka/pull/9838#discussion_r553502329
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2124,12 +2132,14 @@ class Log(@volatile private var _dir: File,
time = time,
hachikuji commented on a change in pull request #9838:
URL: https://github.com/apache/kafka/pull/9838#discussion_r553502329
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2124,12 +2132,14 @@ class Log(@volatile private var _dir: File,
time = time,
hachikuji commented on a change in pull request #9839:
URL: https://github.com/apache/kafka/pull/9839#discussion_r553506242
##
File path: core/src/main/scala/kafka/raft/KafkaNetworkChannel.scala
##
@@ -87,6 +87,7 @@ private[raft] class RaftSendThread(
def sendRequest(reque
ijuma commented on pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#issuecomment-756297605
@chia7712 Can you please remove the last commit? It seems to have a mix of
reverts and it's triggering changes to files I had already reviewed.
chia7712 commented on pull request #9520:
URL: https://github.com/apache/kafka/pull/9520#issuecomment-756299473
> Can you please remove the last commit?
done!
This is an automated message from the Apache Git Service.
T
hachikuji commented on a change in pull request #9839:
URL: https://github.com/apache/kafka/pull/9839#discussion_r553509796
##
File path: core/src/main/scala/kafka/raft/RaftManager.scala
##
@@ -0,0 +1,279 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
junrao commented on a change in pull request #9838:
URL: https://github.com/apache/kafka/pull/9838#discussion_r553511584
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2124,13 +2132,15 @@ class Log(@volatile private var _dir: File,
time = time,
[
https://issues.apache.org/jira/browse/KAFKA-10763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reassigned KAFKA-10763:
-
Assignee: Greg Harris
> Task already exists error on same worker due to skip removal of
junrao commented on a change in pull request #9838:
URL: https://github.com/apache/kafka/pull/9838#discussion_r553524977
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2124,12 +2132,14 @@ class Log(@volatile private var _dir: File,
time = time,
[
https://issues.apache.org/jira/browse/KAFKA-10824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-10824:
--
Component/s: (was: KafkaConnect)
> Connection to node -1 could not be established. Broker
hachikuji commented on a change in pull request #9839:
URL: https://github.com/apache/kafka/pull/9839#discussion_r553526679
##
File path: core/src/main/scala/kafka/raft/RaftManager.scala
##
@@ -0,0 +1,279 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
hachikuji commented on a change in pull request #9839:
URL: https://github.com/apache/kafka/pull/9839#discussion_r553539519
##
File path: core/src/main/scala/kafka/raft/RaftManager.scala
##
@@ -0,0 +1,279 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
[
https://issues.apache.org/jira/browse/KAFKA-10633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-10633:
-
> Constant probing rebalances in Streams 2.6
> --
>
[
https://issues.apache.org/jira/browse/KAFKA-10633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10633.
-
Resolution: Fixed
> Constant probing rebalances in Streams 2.6
> ---
wcarlson5 commented on a change in pull request #9695:
URL: https://github.com/apache/kafka/pull/9695#discussion_r553561353
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AdjustStreamThreadCountTest.java
##
@@ -128,6 +133,7 @@ public void shouldRemove
[
https://issues.apache.org/jira/browse/KAFKA-12155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260796#comment-17260796
]
Jose Armando Garcia Sancio commented on KAFKA-12155:
Another require
[
https://issues.apache.org/jira/browse/KAFKA-12155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260796#comment-17260796
]
Jose Armando Garcia Sancio edited comment on KAFKA-12155 at 1/7/21, 8:33 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-12155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260796#comment-17260796
]
Jose Armando Garcia Sancio edited comment on KAFKA-12155 at 1/7/21, 8:33 PM:
-
chia7712 commented on a change in pull request #9839:
URL: https://github.com/apache/kafka/pull/9839#discussion_r553576422
##
File path: core/src/main/scala/kafka/raft/RaftManager.scala
##
@@ -0,0 +1,279 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or m
hachikuji commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r553562338
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -970,40 +996,98 @@ private FetchResponseData tryCompleteFetchRequest(
hachikuji commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r553598153
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -970,40 +996,98 @@ private FetchResponseData tryCompleteFetchRequest(
wcarlson5 commented on a change in pull request #9720:
URL: https://github.com/apache/kafka/pull/9720#discussion_r553613699
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -526,12 +521,10 @@ public void shouldUp
cyrusv opened a new pull request #9845:
URL: https://github.com/apache/kafka/pull/9845
This is a critical issue (9.8)
https://nvd.nist.gov/vuln/detail/CVE-2020-28052
This is an automated message from the Apache Git Service
hachikuji commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r553598153
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -970,40 +996,98 @@ private FetchResponseData tryCompleteFetchRequest(
hachikuji commented on a change in pull request #9839:
URL: https://github.com/apache/kafka/pull/9839#discussion_r553640245
##
File path: core/src/main/scala/kafka/raft/RaftManager.scala
##
@@ -0,0 +1,279 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
Jason Gustafson created KAFKA-12158:
---
Summary: Consider better return type of RaftClient.scheduleAppend
Key: KAFKA-12158
URL: https://issues.apache.org/jira/browse/KAFKA-12158
Project: Kafka
hachikuji commented on a change in pull request #9839:
URL: https://github.com/apache/kafka/pull/9839#discussion_r553640672
##
File path: clients/src/test/java/org/apache/kafka/clients/MockClient.java
##
@@ -263,8 +263,11 @@ private synchronized void maybeAwaitWakeup() {
Victoria Bialas created KAFKA-12159:
---
Summary: kafka-console-producer prompt should redisplay after an
error output
Key: KAFKA-12159
URL: https://issues.apache.org/jira/browse/KAFKA-12159
Project: K
[
https://issues.apache.org/jira/browse/KAFKA-12159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Victoria Bialas updated KAFKA-12159:
Description:
*BLUF:* The kafka-console-producer should return its prompt after outputting
hachikuji commented on a change in pull request #9839:
URL: https://github.com/apache/kafka/pull/9839#discussion_r553644085
##
File path: core/src/main/scala/kafka/raft/RaftManager.scala
##
@@ -0,0 +1,279 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
[
https://issues.apache.org/jira/browse/KAFKA-12159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Victoria Bialas updated KAFKA-12159:
Description:
*BLUF:* The kafka-console-producer should return its prompt after outputting
[
https://issues.apache.org/jira/browse/KAFKA-12159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Victoria Bialas updated KAFKA-12159:
Description:
*BLUF:* The kafka-console-producer should return its prompt after outputting
[
https://issues.apache.org/jira/browse/KAFKA-12159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Victoria Bialas updated KAFKA-12159:
Description:
*BLUF:* The kafka-console-producer should return its prompt after outputting
hachikuji merged pull request #9807:
URL: https://github.com/apache/kafka/pull/9807
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
[
https://issues.apache.org/jira/browse/KAFKA-12159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Victoria Bialas updated KAFKA-12159:
Description:
*BLUF:* The kafka-console-producer should return its prompt after outputting
[
https://issues.apache.org/jira/browse/KAFKA-10779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-10779.
-
Fix Version/s: 2.8.0
Resolution: Fixed
> Reassignment tool sets throttles incorre
[
https://issues.apache.org/jira/browse/KAFKA-12159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Victoria Bialas updated KAFKA-12159:
Description:
*BLUF:* The kafka-console-producer should return its prompt after outputting
[
https://issues.apache.org/jira/browse/KAFKA-12159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Victoria Bialas updated KAFKA-12159:
Description:
*BLUF:* The kafka-console-producer should return its prompt after outputting
mjsax commented on pull request #9837:
URL: https://github.com/apache/kafka/pull/9837#issuecomment-756459228
@chia7712 -- I miss-typed the ticket number... Fixed now.
The ticket actually discussed the exact same idea as you propose. We just
wanted to get a "quick" doc-improvement out
mjsax merged pull request #9837:
URL: https://github.com/apache/kafka/pull/9837
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
hachikuji commented on a change in pull request #9739:
URL: https://github.com/apache/kafka/pull/9739#discussion_r553666938
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -1050,7 +1050,8 @@ class Log(@volatile private var _dir: File,
leaderEpo
ijuma commented on pull request #9527:
URL: https://github.com/apache/kafka/pull/9527#issuecomment-756466234
Hmm, maybe it's a different override missing, I'll look again.
This is an automated message from the Apache Git Serv
ijuma edited a comment on pull request #9527:
URL: https://github.com/apache/kafka/pull/9527#issuecomment-756466234
Hmm, maybe it's a different override missing (since it's over the map values
collection), I'll look again.
T
mjsax commented on a change in pull request #9835:
URL: https://github.com/apache/kafka/pull/9835#discussion_r553671696
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -377,8 +370,9 @@ private void handleCloseAndRecycle(f
hachikuji commented on a change in pull request #9838:
URL: https://github.com/apache/kafka/pull/9838#discussion_r553693958
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2124,12 +2132,14 @@ class Log(@volatile private var _dir: File,
time = time,
hachikuji commented on a change in pull request #9838:
URL: https://github.com/apache/kafka/pull/9838#discussion_r553693958
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2124,12 +2132,14 @@ class Log(@volatile private var _dir: File,
time = time,
hachikuji commented on a change in pull request #9600:
URL: https://github.com/apache/kafka/pull/9600#discussion_r553701160
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1790,17 +1790,41 @@ class KafkaApis(val requestChannel: RequestChannel,
else
hachikuji commented on a change in pull request #9600:
URL: https://github.com/apache/kafka/pull/9600#discussion_r553701160
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1790,17 +1790,41 @@ class KafkaApis(val requestChannel: RequestChannel,
else
gwenshap commented on a change in pull request #9815:
URL: https://github.com/apache/kafka/pull/9815#discussion_r553705059
##
File path: examples/src/main/java/kafka/examples/Consumer.java
##
@@ -26,33 +25,34 @@
import java.util.Collections;
import java.util.Optional;
import
gwenshap commented on a change in pull request #9815:
URL: https://github.com/apache/kafka/pull/9815#discussion_r553705175
##
File path: examples/src/main/java/kafka/examples/Consumer.java
##
@@ -62,34 +62,24 @@ public Consumer(final String topic,
this.topic = topic;
gwenshap commented on a change in pull request #9815:
URL: https://github.com/apache/kafka/pull/9815#discussion_r553705779
##
File path: examples/src/main/java/kafka/examples/Consumer.java
##
@@ -26,33 +25,34 @@
import java.util.Collections;
import java.util.Optional;
import
hachikuji commented on a change in pull request #9838:
URL: https://github.com/apache/kafka/pull/9838#discussion_r553709529
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2096,10 +2100,14 @@ class Log(@volatile private var _dir: File,
val deletable =
Matthias J. Sax created KAFKA-12160:
---
Summary: KafkaStreams configs are documented incorrectly
Key: KAFKA-12160
URL: https://issues.apache.org/jira/browse/KAFKA-12160
Project: Kafka
Issue T
[
https://issues.apache.org/jira/browse/KAFKA-12160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-12160:
---
Assignee: James Galasyn
> KafkaStreams configs are documented incorrectly
> ---
Jason Gustafson created KAFKA-12161:
---
Summary: Raft observers should not require an id to fetch
Key: KAFKA-12161
URL: https://issues.apache.org/jira/browse/KAFKA-12161
Project: Kafka
Issue
chia7712 merged pull request #9843:
URL: https://github.com/apache/kafka/pull/9843
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
chia7712 commented on a change in pull request #9839:
URL: https://github.com/apache/kafka/pull/9839#discussion_r553735392
##
File path: core/src/main/scala/kafka/raft/RaftManager.scala
##
@@ -0,0 +1,279 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or m
[
https://issues.apache.org/jira/browse/KAFKA-9965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260987#comment-17260987
]
Sandeep S commented on KAFKA-9965:
--
Hi, I am facing similar issue.
|GROUP
chia7712 commented on pull request #9746:
URL: https://github.com/apache/kafka/pull/9746#issuecomment-756542270
@dajac @ijuma Could you please take a look?
This is an automated message from the Apache Git Service.
To respond
chia7712 commented on pull request #8943:
URL: https://github.com/apache/kafka/pull/8943#issuecomment-756547174
The other tools (written by java) has similar issue. For example,
```VerifiableConsumer``` and ```VerifiableProducer```. Could we have a helper
method like ```printHelpAndExitIfN
[
https://issues.apache.org/jira/browse/KAFKA-9965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260987#comment-17260987
]
Sandeep S edited comment on KAFKA-9965 at 1/8/21, 5:06 AM:
---
Hi,
hachikuji commented on a change in pull request #9839:
URL: https://github.com/apache/kafka/pull/9839#discussion_r553749199
##
File path: core/src/main/scala/kafka/raft/RaftManager.scala
##
@@ -0,0 +1,279 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
chia7712 commented on a change in pull request #9839:
URL: https://github.com/apache/kafka/pull/9839#discussion_r553756881
##
File path: core/src/main/scala/kafka/raft/RaftManager.scala
##
@@ -0,0 +1,279 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or m
Badai Aqrandista created KAFKA-12162:
Summary: Kafka broker continued to run after failing to create
"/brokers/ids/X" znode.
Key: KAFKA-12162
URL: https://issues.apache.org/jira/browse/KAFKA-12162
Badai Aqrandista created KAFKA-12163:
Summary: Controller should ensure zkVersion is monotonically
increasing when sending UpdateMetadata requests.
Key: KAFKA-12163
URL: https://issues.apache.org/jira/browse/K
1 - 100 of 104 matches
Mail list logo
