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]"
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
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) {
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 @@
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 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
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.
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
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 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 #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 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 #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 #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 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 #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 #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 #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 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
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
[
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
[
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
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
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) {
[
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.
[
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
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
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
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
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
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 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
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 #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
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 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 #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?
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 #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
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
[
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
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
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
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
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
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 #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 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 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 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 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 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 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 #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 #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 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 #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 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 #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
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
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 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
[
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
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-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
[
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-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-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-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-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-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-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: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-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-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.
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-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
[
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
> ---
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
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 @@
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) {
[
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
[
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-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
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
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_r799428683
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
##
@@ -578,41 +587,45 @@ private boolean
shouldStop
[
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
[ 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-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:
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
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
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
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
96 matches
Mail list logo
