ableegoldman commented on a change in pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#discussion_r799253840
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/TopologyConfig.java
##
@@ -116,14 +123,30 @@ public T
ableegoldman commented on a change in pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#discussion_r799261397
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -1034,14 +1037,15 @@ private static Metrics getMetrics(final Str
predatorray commented on pull request #10525:
URL: https://github.com/apache/kafka/pull/10525#issuecomment-1029767796
@guozhangwang Thanks for the reply and the review. The change was rebased.
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
satishd commented on a change in pull request #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r796465473
##
File path:
clients/src/main/java/org/apache/kafka/common/record/RemoteLogInputStream.java
##
@@ -0,0 +1,75 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/KAFKA-12635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486576#comment-17486576
]
Federico Valeri edited comment on KAFKA-12635 at 2/4/22, 8:51 AM:
[ https://issues.apache.org/jira/browse/KAFKA-12635 ]
Federico Valeri deleted comment on KAFKA-12635:
-
was (Author: fvaleri):
I was able to reproduce the issue on Kafka 2.7.2 and 2.8.1, but not on 3.1.0.
State of the source cluster after pr
[
https://issues.apache.org/jira/browse/KAFKA-13626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486916#comment-17486916
]
Daniel Häuser commented on KAFKA-13626:
---
[~Kvicii]
I don't know exactly what hap
ijuma commented on a change in pull request #11722:
URL: https://github.com/apache/kafka/pull/11722#discussion_r799428683
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
##
@@ -578,41 +587,45 @@ private boolean
shouldStop
ijuma commented on a change in pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#discussion_r799456068
##
File path:
clients/src/test/java/org/apache/kafka/common/utils/ByteUtilsTest.java
##
@@ -239,6 +239,66 @@ public void testDouble() throws IOException {
ijuma commented on a change in pull request #11722:
URL: https://github.com/apache/kafka/pull/11722#discussion_r799462063
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
##
@@ -448,40 +448,48 @@ public ReadyCheckResult rea
[
https://issues.apache.org/jira/browse/KAFKA-13600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487148#comment-17487148
]
Bruno Cadonna commented on KAFKA-13600:
---
I am fine with discussing the improvement
[
https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487184#comment-17487184
]
Bruno Cadonna commented on KAFKA-13638:
---
[~Lejon] How did you measure time with yo
[
https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487211#comment-17487211
]
Ulrik commented on KAFKA-13638:
---
[~cadonna] i ran the test from within Intellij and just t
hachikuji commented on a change in pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#discussion_r799691615
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
##
@@ -514,12 +512,11 @@ public ProducerConfig(Map props) {
ijuma commented on a change in pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#discussion_r799697679
##
File path: docs/upgrade.html
##
@@ -19,6 +19,13 @@
cmccabe commented on pull request #11659:
URL: https://github.com/apache/kafka/pull/11659#issuecomment-1030241564
Thanks for the PR, @dengziming.
The broker validation needs to be done on the broker side, since the broker
has access to information that the controller does not. For ex
[
https://issues.apache.org/jira/browse/KAFKA-13503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-13503.
--
Fix Version/s: 3.2.0
Reviewer: Jose Armando Garcia Sancio
Assignee: Colin McC
[
https://issues.apache.org/jira/browse/KAFKA-13552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-13552:
-
Fix Version/s: 3.2.0
> Unable to dynamically change broker log levels on KRaft
> ---
[
https://issues.apache.org/jira/browse/KAFKA-13503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487221#comment-17487221
]
Colin McCabe commented on KAFKA-13503:
--
The PR for KAFKA-13552 added broker-side va
guozhangwang commented on a change in pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#discussion_r799712506
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -1034,14 +1037,15 @@ private static Metrics getMetrics(final Str
[
https://issues.apache.org/jira/browse/KAFKA-9154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-9154.
-
Fix Version/s: 3.1.0
Resolution: Fixed
We implemented KIP-730 in Kafka 3.1. Closing this.
[
https://issues.apache.org/jira/browse/KAFKA-9837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487226#comment-17487226
]
Colin McCabe commented on KAFKA-9837:
-
I'm sorry that there hasn't been any activity
[
https://issues.apache.org/jira/browse/KAFKA-10724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487230#comment-17487230
]
Colin McCabe commented on KAFKA-10724:
--
The command has been renamed to {{raft/bin/
[
https://issues.apache.org/jira/browse/KAFKA-10724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe reassigned KAFKA-10724:
Assignee: Jason Gustafson
> Command to run single quorum in raft is missing "--config" pa
[
https://issues.apache.org/jira/browse/KAFKA-10724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-10724.
--
Resolution: Fixed
> Command to run single quorum in raft is missing "--config" parameters.
> -
[
https://issues.apache.org/jira/browse/KAFKA-12209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-12209.
--
Fix Version/s: 2.8.0
Assignee: Colin McCabe
Resolution: Fixed
> Add the timeli
[
https://issues.apache.org/jira/browse/KAFKA-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-12214.
--
Resolution: Fixed
> Generated code does not include UUID or struct fields in its toString outp
[
https://issues.apache.org/jira/browse/KAFKA-12271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-12271.
--
Fix Version/s: 3.0.0
Resolution: Fixed
> Expose consistent Raft metadata to components
[
https://issues.apache.org/jira/browse/KAFKA-12421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487233#comment-17487233
]
Colin McCabe commented on KAFKA-12421:
--
We did introduce a distinction between atom
[
https://issues.apache.org/jira/browse/KAFKA-12421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-12421.
--
Assignee: Jose Armando Garcia Sancio (was: HaiyuanZhao)
Resolution: Fixed
> Improve con
[
https://issues.apache.org/jira/browse/KAFKA-12502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe reassigned KAFKA-12502:
Assignee: Colin McCabe (was: Ryan Dielhenn)
> Quorum controller should return topic conf
Colin McCabe created KAFKA-13646:
Summary: Implement KIP-801: KRaft authorizer
Key: KAFKA-13646
URL: https://issues.apache.org/jira/browse/KAFKA-13646
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-13193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-13193.
--
Resolution: Fixed
> Replica manager doesn't update partition state when transitioning from lea
jasonk000 commented on pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#issuecomment-1030278393
Thanks @ijuma , I believe I've sorted these out in
[e891ebf](https://github.com/apache/kafka/pull/11721/commits/e891ebfd46ed97ab1c6face21f3d7f6565734a77).
--
This is an aut
jasonk000 commented on a change in pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#discussion_r799747533
##
File path:
clients/src/test/java/org/apache/kafka/common/utils/ByteUtilsTest.java
##
@@ -239,6 +239,66 @@ public void testDouble() throws IOExceptio
jasonk000 commented on a change in pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#discussion_r799748066
##
File path:
clients/src/test/java/org/apache/kafka/common/utils/ByteUtilsTest.java
##
@@ -239,6 +239,66 @@ public void testDouble() throws IOExceptio
dajac commented on pull request #11543:
URL: https://github.com/apache/kafka/pull/11543#issuecomment-1030295682
@shharrnam Thanks for the PR. Could you explain why we would need to add
this new line? That does not seem necessary to me.
--
This is an automated message from the Apache Git
dajac closed pull request #11594:
URL: https://github.com/apache/kafka/pull/11594
--
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...
dajac commented on pull request #11594:
URL: https://github.com/apache/kafka/pull/11594#issuecomment-1030299168
@ayu-programer It depends on your use case. You could consume all the topics
from the same group if the application needs to process all of them together.
Otherwise, you can defi
dajac commented on pull request #11353:
URL: https://github.com/apache/kafka/pull/11353#issuecomment-1030306522
@mprusakov Are you still interested by doing this? I can help reviewing the
PR once the existing comments are addressed. Thanks.
--
This is an automated message from the Apache
dajac commented on pull request #10562:
URL: https://github.com/apache/kafka/pull/10562#issuecomment-1030315113
Closing as this was done by another PR.
--
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
dajac closed pull request #10562:
URL: https://github.com/apache/kafka/pull/10562
--
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...
dajac commented on pull request #9963:
URL: https://github.com/apache/kafka/pull/9963#issuecomment-1030320056
Closing.
--
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 u
dajac closed pull request #9963:
URL: https://github.com/apache/kafka/pull/9963
--
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...@k
dajac closed pull request #9402:
URL: https://github.com/apache/kafka/pull/9402
--
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...@k
dajac commented on pull request #9402:
URL: https://github.com/apache/kafka/pull/9402#issuecomment-1030324045
This was done by https://github.com/apache/kafka/pull/11008. Closing it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
dajac commented on pull request #9289:
URL: https://github.com/apache/kafka/pull/9289#issuecomment-1030325227
I am sure what this PR is doing. It seems to be a mistake. Closing it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
dajac closed pull request #9289:
URL: https://github.com/apache/kafka/pull/9289
--
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...@k
dajac closed pull request #9085:
URL: https://github.com/apache/kafka/pull/9085
--
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...@k
dajac commented on pull request #9085:
URL: https://github.com/apache/kafka/pull/9085#issuecomment-1030326392
PR is outdated. Closing it.
--
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 spec
dajac closed pull request #7456:
URL: https://github.com/apache/kafka/pull/7456
--
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...@k
jasonk000 commented on a change in pull request #11722:
URL: https://github.com/apache/kafka/pull/11722#discussion_r799796771
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
##
@@ -448,40 +448,48 @@ public ReadyCheckResult
mprusakov closed pull request #11353:
URL: https://github.com/apache/kafka/pull/11353
--
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-unsubsc
mprusakov commented on pull request #11353:
URL: https://github.com/apache/kafka/pull/11353#issuecomment-1030340572
Unfortunately i have realized that this fix is a drop in the ocean and
further changes are much more intrusive. This change alone did not meet my
client's requirements so I'v
[
https://issues.apache.org/jira/browse/KAFKA-13322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Michail resolved KAFKA-13322.
-
Resolution: Won't Fix
Having done the analysis the changes required to achieve this are far too
intrusi
hachikuji commented on a change in pull request #11667:
URL: https://github.com/apache/kafka/pull/11667#discussion_r799823851
##
File path: core/src/test/scala/unit/kafka/server/ApiVersionsRequestTest.scala
##
@@ -17,41 +17,35 @@
package kafka.server
-import kafka.test.{Cl
hachikuji commented on pull request #11685:
URL: https://github.com/apache/kafka/pull/11685#issuecomment-1030368363
@shubhamsingh002 Can you clarify your intent here? The upgrade to log4j 2 is
not compatible and we are not planning to release from 0.10 in any case as far
as I know.
--
T
ijuma commented on a change in pull request #11722:
URL: https://github.com/apache/kafka/pull/11722#discussion_r799828526
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
##
@@ -448,40 +448,48 @@ public ReadyCheckResult rea
hachikuji commented on pull request #11646:
URL: https://github.com/apache/kafka/pull/11646#issuecomment-1030373051
@showuon Thanks for the PR and apologies for the delay. It looks to me like
this is covering both the consumer and producer? Would it be possible to
separate into two PRs?
hachikuji closed pull request #11685:
URL: https://github.com/apache/kafka/pull/11685
--
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-unsubsc
hachikuji commented on pull request #11685:
URL: https://github.com/apache/kafka/pull/11685#issuecomment-1030374498
I am going to go ahead and close this. Please feel free to reopen after you
have updated the description to explain what you are trying to do.
--
This is an automated messa
hachikuji commented on a change in pull request #11620:
URL: https://github.com/apache/kafka/pull/11620#discussion_r799835234
##
File path: core/src/test/scala/integration/kafka/server/QuorumTestHarness.scala
##
@@ -340,6 +340,7 @@ abstract class QuorumTestHarness extends Loggi
ijuma commented on a change in pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#discussion_r799833387
##
File path: clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java
##
@@ -413,15 +424,20 @@ public static int sizeOfVarint(int value) {
ijuma commented on a change in pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#discussion_r799833387
##
File path: clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java
##
@@ -413,15 +424,20 @@ public static int sizeOfVarint(int value) {
hachikuji commented on a change in pull request #11688:
URL: https://github.com/apache/kafka/pull/11688#discussion_r799847085
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -696,8 +698,12 @@ public void handle(Joi
lbradstreet commented on a change in pull request #11620:
URL: https://github.com/apache/kafka/pull/11620#discussion_r799864255
##
File path: core/src/test/scala/integration/kafka/server/QuorumTestHarness.scala
##
@@ -340,6 +340,7 @@ abstract class QuorumTestHarness extends Log
hachikuji opened a new pull request #11734:
URL: https://github.com/apache/kafka/pull/11734
We allowed `maxProducerIdExpirationMs` and `time` to be optional in the
`ProducerStateManager` constructor. We generally frown on optional arguments
since it is too easy to overlook them. In this ca
hachikuji merged pull request #11694:
URL: https://github.com/apache/kafka/pull/11694
--
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-unsubsc
jasonk000 commented on a change in pull request #11722:
URL: https://github.com/apache/kafka/pull/11722#discussion_r799904384
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
##
@@ -448,40 +448,48 @@ public ReadyCheckResult
jasonk000 commented on a change in pull request #11722:
URL: https://github.com/apache/kafka/pull/11722#discussion_r799905219
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
##
@@ -448,40 +448,48 @@ public ReadyCheckResult
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-12984:
---
Fix Version/s: 2.5.2
2.6.2
2.7.1
> Coo
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-12984:
---
Fix Version/s: 2.7.2
2.6.3
(was: 2.
ableegoldman commented on a change in pull request #11712:
URL: https://github.com/apache/kafka/pull/11712#discussion_r799919908
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java
##
@@ -270,6 +278,23 @@ Task task(final TaskId taskId) {
jasonk000 commented on pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#issuecomment-1030489854
I've addressed comments, I'll wait and see what spotbugs says this time.
Locally, it's all clear, on CI it shows up issues with code not related to this
PR.
--
This is an
[
https://issues.apache.org/jira/browse/KAFKA-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13346.
---
Resolution: Not A Problem
> Kafka Streams fails due to RocksDB Locks Not Available Exception
[
https://issues.apache.org/jira/browse/KAFKA-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487405#comment-17487405
]
Guozhang Wang commented on KAFKA-13346:
---
I'm closing this ticket for now since we
Kvicii commented on pull request #11543:
URL: https://github.com/apache/kafka/pull/11543#issuecomment-1030526684
@dajac
This is unnecessary, I think this PR can be closed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
ijuma commented on pull request #11586:
URL: https://github.com/apache/kafka/pull/11586#issuecomment-1030531283
Cc @apovzner @splett2
--
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 specifi
ijuma commented on pull request #11579:
URL: https://github.com/apache/kafka/pull/11579#issuecomment-1030531381
Thanks for the PR. Seems like the new version has more false positives. Do
you know if they intend to fix those?
--
This is an automated message from the Apache Git Service.
To
ijuma closed pull request #11543:
URL: https://github.com/apache/kafka/pull/11543
--
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 #11469:
URL: https://github.com/apache/kafka/pull/11469#issuecomment-1030532433
Any reason why this wasn't merged?
--
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
ijuma closed pull request #11377:
URL: https://github.com/apache/kafka/pull/11377
--
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 #11376:
URL: https://github.com/apache/kafka/pull/11376#issuecomment-1030532699
Are you planning to address the comments @lbradstreet ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
ijuma commented on pull request #11137:
URL: https://github.com/apache/kafka/pull/11137#issuecomment-1030532879
@wycc are you planning to address the comments?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
ijuma commented on pull request #11159:
URL: https://github.com/apache/kafka/pull/11159#issuecomment-1030533071
@jsancio are you going to merge this?
--
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
ijuma commented on pull request #11161:
URL: https://github.com/apache/kafka/pull/11161#issuecomment-1030533145
@rajinisivaram friendly ping.
--
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
ijuma commented on a change in pull request #11204:
URL: https://github.com/apache/kafka/pull/11204#discussion_r78166
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClientResponseWithFinalize.java
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software Fo
ijuma commented on pull request #11229:
URL: https://github.com/apache/kafka/pull/11229#issuecomment-1030533521
@dajac is this still relevant?
--
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
ijuma commented on pull request #11238:
URL: https://github.com/apache/kafka/pull/11238#issuecomment-1030533632
Cc @jsancio @cmccabe
--
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
showuon closed pull request #11661:
URL: https://github.com/apache/kafka/pull/11661
--
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.
showuon commented on pull request #11646:
URL: https://github.com/apache/kafka/pull/11646#issuecomment-1030567555
@hachikuji , thanks for the comment. Yes, actually I've separated producer
and consumer into 2 PRs. (actually, there's 3rd one for adminClient). It's just
there are still some
ableegoldman commented on a change in pull request #11712:
URL: https://github.com/apache/kafka/pull/11712#discussion_r800029186
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java
##
@@ -270,6 +278,23 @@ Task task(final TaskId taskId) {
showuon commented on a change in pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#discussion_r800029493
##
File path: docs/upgrade.html
##
@@ -19,6 +19,13 @@
showuon commented on a change in pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#discussion_r800030072
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
##
@@ -514,12 +512,11 @@ public ProducerConfig(Map props) {
dajac commented on a change in pull request #11586:
URL: https://github.com/apache/kafka/pull/11586#discussion_r800030837
##
File path: clients/src/main/java/org/apache/kafka/common/network/Selector.java
##
@@ -1144,7 +1149,11 @@ public void close() {
public SelectorMe
runom opened a new pull request #11735:
URL: https://github.com/apache/kafka/pull/11735
Currently, `bin/kafka-consumer-groups.sh --version` reqiures unnecessary
`bootstrap-server` option.
```
% bin/kafka-consumer-groups.sh --version
Missing required argument "[bootstrap-server]"
96 matches
Mail list logo
