[
https://issues.apache.org/jira/browse/KAFKA-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-15670:
--
Summary: KRaft controller should set inter broker listener when migration
(was: KRaft controller usin
[
https://issues.apache.org/jira/browse/KAFKA-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-15670:
--
Description:
During ZK migrating to KRaft, before entering dual-write mode, the KRaft
controller will
dajac commented on code in PR #14524:
URL: https://github.com/apache/kafka/pull/14524#discussion_r1371278858
##
tests/kafkatest/services/kafka/kafka.py:
##
@@ -277,6 +279,22 @@ def __init__(self, context, num_nodes, zk,
security_protocol=SecurityConfig.PLAI
self.isolat
dajac commented on code in PR #14524:
URL: https://github.com/apache/kafka/pull/14524#discussion_r1371289551
##
tests/kafkatest/services/kafka/kafka.py:
##
@@ -277,6 +279,22 @@ def __init__(self, context, num_nodes, zk,
security_protocol=SecurityConfig.PLAI
self.isolat
hudeqi commented on PR #13847:
URL: https://github.com/apache/kafka/pull/13847#issuecomment-1778716871
I mentioned a [PR](https://github.com/apache/kafka/pull/13421) before, which
is aimed at the problem that an abnormality in copying data may occur when
performing `alterlog`, causing the p
soarez commented on code in PR #14625:
URL: https://github.com/apache/kafka/pull/14625#discussion_r1371337334
##
clients/src/test/java/org/apache/kafka/common/record/DefaultRecordBatchTest.java:
##
@@ -63,15 +61,7 @@
import static org.mockito.Mockito.when;
public class Defau
[
https://issues.apache.org/jira/browse/KAFKA-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Soarez reassigned KAFKA-15362:
---
Assignee: Igor Soarez
> Resolve offline replicas in metadata cache
> -
soarez commented on code in PR #14517:
URL: https://github.com/apache/kafka/pull/14517#discussion_r1371360492
##
clients/src/main/java/org/apache/kafka/common/Uuid.java:
##
@@ -49,21 +49,21 @@ public class Uuid implements Comparable {
/**
* A UUID that is used to iden
msn-tldr commented on code in PR #14564:
URL: https://github.com/apache/kafka/pull/14564#discussion_r1370531714
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java:
##
@@ -171,6 +179,15 @@ protected void handleFetchResponse(final Node fetchTar
msn-tldr commented on code in PR #14564:
URL: https://github.com/apache/kafka/pull/14564#discussion_r1370531714
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java:
##
@@ -171,6 +179,15 @@ protected void handleFetchResponse(final Node fetchTar
soarez commented on code in PR #14290:
URL: https://github.com/apache/kafka/pull/14290#discussion_r1371372722
##
metadata/src/main/java/org/apache/kafka/controller/PartitionChangeBuilder.java:
##
@@ -54,6 +54,7 @@ public static boolean
changeRecordIsNoOp(PartitionChangeRecord r
rd-dreich commented on PR #11430:
URL: https://github.com/apache/kafka/pull/11430#issuecomment-1778795647
Hi @dongjinleekr and @rajinisivaram. Are there any news regarding this PR?
We're currently dealing with this issue due to some keycloak limitations and it
would be great if this bug wou
soarez commented on code in PR #14290:
URL: https://github.com/apache/kafka/pull/14290#discussion_r1371390386
##
metadata/src/main/resources/common/metadata/PartitionRecord.json:
##
@@ -47,6 +47,13 @@
"about": "The eligible leader replicas of this partition." },
{ "n
msn-tldr commented on code in PR #14564:
URL: https://github.com/apache/kafka/pull/14564#discussion_r1370368421
##
clients/src/main/java/org/apache/kafka/clients/MetadataCache.java:
##
@@ -150,7 +150,7 @@ MetadataCache mergeWith(String newClusterId,
// We want the most
msn-tldr commented on code in PR #14564:
URL: https://github.com/apache/kafka/pull/14564#discussion_r1370368421
##
clients/src/main/java/org/apache/kafka/clients/MetadataCache.java:
##
@@ -150,7 +150,7 @@ MetadataCache mergeWith(String newClusterId,
// We want the most
msn-tldr commented on code in PR #14564:
URL: https://github.com/apache/kafka/pull/14564#discussion_r1370368421
##
clients/src/main/java/org/apache/kafka/clients/MetadataCache.java:
##
@@ -150,7 +150,7 @@ MetadataCache mergeWith(String newClusterId,
// We want the most
msn-tldr commented on code in PR #14564:
URL: https://github.com/apache/kafka/pull/14564#discussion_r1370368421
##
clients/src/main/java/org/apache/kafka/clients/MetadataCache.java:
##
@@ -150,7 +150,7 @@ MetadataCache mergeWith(String newClusterId,
// We want the most
divijvaidya commented on code in PR #13321:
URL: https://github.com/apache/kafka/pull/13321#discussion_r1371421492
##
bin/kafka-run-class.sh:
##
@@ -229,7 +230,7 @@ if [ -z "$KAFKA_LOG4J_OPTS" ]; then
# Log to console. This is a tool.
LOG4J_DIR="$base_dir/config/tools-log4
divijvaidya commented on PR #14622:
URL: https://github.com/apache/kafka/pull/14622#issuecomment-1778850349
Unrelated test failures:
```
[Build / JDK 21 and Scala 2.13 /
integration.kafka.server.FetchFromFollowerIntegrationTest.testRackAwareRangeAssignor(String).quorum=zk](https://ci-b
divijvaidya merged PR #14622:
URL: https://github.com/apache/kafka/pull/14622
--
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...@kafka.apa
[
https://issues.apache.org/jira/browse/KAFKA-15671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya resolved KAFKA-15671.
--
Resolution: Fixed
> Flaky test RemoteIndexCacheTest.testClearCacheAndIndexFilesWhenResizeCache
[
https://issues.apache.org/jira/browse/KAFKA-15671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15671:
-
Fix Version/s: 3.7.0
> Flaky test RemoteIndexCacheTest.testClearCacheAndIndexFilesWhenResizeCach
msn-tldr commented on PR #14627:
URL: https://github.com/apache/kafka/pull/14627#issuecomment-1778870153
@chb2ab lgtm, thanks for raising 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 to the
[
https://issues.apache.org/jira/browse/KAFKA-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779426#comment-17779426
]
Divij Vaidya commented on KAFKA-15388:
--
Hey [~goyarpit]
I would suggest the follo
AndrewJSchofield commented on code in PR #14564:
URL: https://github.com/apache/kafka/pull/14564#discussion_r1371441595
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java:
##
@@ -685,6 +711,13 @@ private void completeBatch(ProducerBatch batch,
Prod
maniekes commented on code in PR #13321:
URL: https://github.com/apache/kafka/pull/13321#discussion_r1371452345
##
bin/kafka-run-class.sh:
##
@@ -229,7 +230,7 @@ if [ -z "$KAFKA_LOG4J_OPTS" ]; then
# Log to console. This is a tool.
LOG4J_DIR="$base_dir/config/tools-log4j.p
kumarpritam863 commented on PR #14630:
URL: https://github.com/apache/kafka/pull/14630#issuecomment-1778892134
@C0urante Can you please review?
--
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-15364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim reassigned KAFKA-15364:
-
Assignee: Omnia Ibrahim
> Handle log directory failure in the Controller
>
msn-tldr commented on code in PR #14564:
URL: https://github.com/apache/kafka/pull/14564#discussion_r1371479753
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java:
##
@@ -614,13 +618,28 @@ private void handleProduceResponse(ClientResponse
response,
clolov commented on PR #14623:
URL: https://github.com/apache/kafka/pull/14623#issuecomment-1778922834
Local run of the failing tests passes:
```
> Configure project :
Starting build with version 3.7.0-SNAPSHOT (commit id 79afb498) using Gradle
8.3, Java 1.8 and Scala 2.13.12
Bui
divijvaidya commented on code in PR #14628:
URL: https://github.com/apache/kafka/pull/14628#discussion_r1371459493
##
metadata/src/main/java/org/apache/kafka/metadata/properties/PropertiesUtils.java:
##
@@ -0,0 +1,102 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
divijvaidya commented on code in PR #13321:
URL: https://github.com/apache/kafka/pull/13321#discussion_r1371485060
##
bin/kafka-run-class.sh:
##
@@ -229,7 +230,7 @@ if [ -z "$KAFKA_LOG4J_OPTS" ]; then
# Log to console. This is a tool.
LOG4J_DIR="$base_dir/config/tools-log4
Apoorv Mittal created KAFKA-15681:
-
Summary: Add support of client-metrics in kafka-configs.sh
Key: KAFKA-15681
URL: https://issues.apache.org/jira/browse/KAFKA-15681
Project: Kafka
Issue Typ
divijvaidya commented on PR #14242:
URL: https://github.com/apache/kafka/pull/14242#issuecomment-1778956865
Hey @ocadaruma
This is an important change, so I despite low engagement on this from me, I
do believe that this change is critical. Let's think carefully about this.
I would
[
https://issues.apache.org/jira/browse/KAFKA-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-15670:
--
Description:
During ZK migrating to KRaft, before entering dual-write mode, the KRaft
controller will
showuon opened a new pull request, #14631:
URL: https://github.com/apache/kafka/pull/14631
During ZK migrating to KRaft, before entering dual-write mode, the KRaft
controller will send RPCs (i.e. UpdateMetadataRequest, LeaderAndIsrRequest, and
StopReplicaRequest) to the brokers. Currently,
showuon commented on PR #14631:
URL: https://github.com/apache/kafka/pull/14631#issuecomment-1778977394
@mumrah @cmccabe , call for review. Thanks.
--
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
apoorvmittal10 opened a new pull request, #14632:
URL: https://github.com/apache/kafka/pull/14632
The PR adds support of alter/describe configs for client-metrics as defined
in
[KIP-714](https://cwiki.apache.org/confluence/display/KAFKA/KIP-714%3A+Client+metrics+and+observability#KIP714:Cli
AndrewJSchofield commented on code in PR #14632:
URL: https://github.com/apache/kafka/pull/14632#discussion_r1371529124
##
core/src/main/scala/kafka/admin/ConfigCommand.scala:
##
@@ -445,6 +446,21 @@ object ConfigCommand extends Logging {
if (unknownConfigs.nonEmpty)
ppatierno commented on code in PR #14631:
URL: https://github.com/apache/kafka/pull/14631#discussion_r1371542283
##
docs/ops.html:
##
@@ -3819,6 +3819,9 @@ Provisioning the KRaft controller quorum
# ZooKeeper client configuration
zookeeper.connect=localhost:2181
+# The inter
soarez commented on PR #14516:
URL: https://github.com/apache/kafka/pull/14516#issuecomment-1779020910
Thanks for the review and comments @OmniaGM . Depending on the outcome of
the current discussion in #14290 there may be some bigger changes to this PR,
so I'll wait until that's resolved b
[
https://issues.apache.org/jira/browse/KAFKA-15364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim reassigned KAFKA-15364:
-
Assignee: (was: Omnia Ibrahim)
> Handle log directory failure in the Controller
> -
[
https://issues.apache.org/jira/browse/KAFKA-15363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim reassigned KAFKA-15363:
-
Assignee: Omnia Ibrahim
> Broker log directory failure changes
> --
AndrewJSchofield commented on code in PR #14632:
URL: https://github.com/apache/kafka/pull/14632#discussion_r1371581178
##
core/src/main/scala/kafka/admin/ConfigCommand.scala:
##
@@ -445,6 +446,21 @@ object ConfigCommand extends Logging {
if (unknownConfigs.nonEmpty)
soarez commented on code in PR #14578:
URL: https://github.com/apache/kafka/pull/14578#discussion_r1371577705
##
core/src/main/scala/kafka/log/LogManager.scala:
##
@@ -270,26 +270,38 @@ class LogManager(logDirs: Seq[File],
def directoryId(dir: String): Option[Uuid] = dirIds.g
ocadaruma commented on PR #14242:
URL: https://github.com/apache/kafka/pull/14242#issuecomment-1779076146
@divijvaidya Thank you for your review.
> > But now, since we are flushing snapshot async & quietly
During reading your comment, I found that "quietly"
--
This is an automat
vamossagar12 commented on code in PR #14327:
URL: https://github.com/apache/kafka/pull/14327#discussion_r1371564208
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroup.java:
##
@@ -727,20 +728,42 @@ private void maybeUpdateSubscribedTopic
ocadaruma commented on PR #14242:
URL: https://github.com/apache/kafka/pull/14242#issuecomment-1779086343
@divijvaidya Thank you for your review.
> But now, since we are flushing snapshot async & quietly
During reading your comment, I realized that "quietly" could be a problem s
apoorvmittal10 commented on code in PR #14632:
URL: https://github.com/apache/kafka/pull/14632#discussion_r1371629188
##
core/src/main/scala/kafka/admin/ConfigCommand.scala:
##
@@ -445,6 +446,21 @@ object ConfigCommand extends Logging {
if (unknownConfigs.nonEmpty)
apoorvmittal10 commented on code in PR #14632:
URL: https://github.com/apache/kafka/pull/14632#discussion_r1371639259
##
core/src/main/scala/kafka/admin/ConfigCommand.scala:
##
@@ -576,6 +594,8 @@ object ConfigCommand extends Logging {
if (entityName.nonEmpty)
apoorvmittal10 commented on code in PR #14632:
URL: https://github.com/apache/kafka/pull/14632#discussion_r1371642341
##
core/src/main/scala/kafka/admin/ConfigCommand.scala:
##
@@ -536,6 +552,8 @@ object ConfigCommand extends Logging {
adminClient.listTopics(new
List
pprovenzano commented on code in PR #14578:
URL: https://github.com/apache/kafka/pull/14578#discussion_r1371668063
##
core/src/main/scala/kafka/log/LogManager.scala:
##
@@ -270,26 +270,38 @@ class LogManager(logDirs: Seq[File],
def directoryId(dir: String): Option[Uuid] = dir
mdedetrich commented on PR #12728:
URL: https://github.com/apache/kafka/pull/12728#issuecomment-1779161332
@mimaison @ijuma I have just finished PR and I can confirm the tests are
passing locally. Due to the fact we are no longer dealing with static classes,
the setting up of the static moc
tkornai opened a new pull request, #14633:
URL: https://github.com/apache/kafka/pull/14633
Using a custom security.provider may keep shell commands running
indefinitely if System.exit() is not called explicitly. This behaviour is due
to the reason that a security.provider implementation mig
Kamal Chandraprakash created KAFKA-15682:
Summary: Ensure internal remote log metadata topic does not expire
its segments before deleting user-topic segments
Key: KAFKA-15682
URL: https://issues.apache.org
[
https://issues.apache.org/jira/browse/KAFKA-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash updated KAFKA-15682:
-
Description:
One of the implementation of RemoteLogMetadataManager is
TopicBase
[
https://issues.apache.org/jira/browse/KAFKA-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash updated KAFKA-15682:
-
Description:
One of the implementation of RemoteLogMetadataManager is
TopicBase
kamalcph commented on code in PR #14576:
URL: https://github.com/apache/kafka/pull/14576#discussion_r1371713733
##
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataCache.java:
##
@@ -157,13 +157,20 @@ public void
updateRemoteLogSegmentM
[
https://issues.apache.org/jira/browse/KAFKA-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash updated KAFKA-15682:
-
Description:
One of the implementation of RemoteLogMetadataManager is
TopicBase
apoorvmittal10 commented on code in PR #14575:
URL: https://github.com/apache/kafka/pull/14575#discussion_r1371720108
##
clients/src/main/java/org/apache/kafka/common/telemetry/ClientTelemetry.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
showuon commented on code in PR #14631:
URL: https://github.com/apache/kafka/pull/14631#discussion_r1371720987
##
docs/ops.html:
##
@@ -3819,6 +3819,9 @@ Provisioning the KRaft controller quorum
# ZooKeeper client configuration
zookeeper.connect=localhost:2181
+# The inter b
[
https://issues.apache.org/jira/browse/KAFKA-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash updated KAFKA-15682:
-
Description:
One of the implementation of RemoteLogMetadataManager is
TopicBase
ppatierno commented on code in PR #14631:
URL: https://github.com/apache/kafka/pull/14631#discussion_r1371736949
##
docs/ops.html:
##
@@ -3822,6 +3822,9 @@ Provisioning the KRaft controller quorum
# The inter broker listener in brokers to allow KRaft controller send RPCs to
br
apoorvmittal10 commented on PR #14632:
URL: https://github.com/apache/kafka/pull/14632#issuecomment-1779271622
Build depends on PR - https://github.com/apache/kafka/pull/14621
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
ijuma commented on PR #12728:
URL: https://github.com/apache/kafka/pull/12728#issuecomment-1779282256
@mimaison Do you have the cycles to review 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 PR #14410:
URL: https://github.com/apache/kafka/pull/14410#issuecomment-1779286800
@divijvaidya Do you have cycles to review 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 code in PR #14410:
URL: https://github.com/apache/kafka/pull/14410#discussion_r1371770193
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsProducerTest.java:
##
@@ -197,8 +203,7 @@ public void before() {
);
eos
aliehsaeedii opened a new pull request, #14634:
URL: https://github.com/apache/kafka/pull/14634
This is the PoC PR for KIP-969.
--
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 commen
rondagostino commented on code in PR #14290:
URL: https://github.com/apache/kafka/pull/14290#discussion_r1371825053
##
metadata/src/main/resources/common/metadata/PartitionRecord.json:
##
@@ -47,6 +47,13 @@
"about": "The eligible leader replicas of this partition." },
dajac commented on code in PR #14589:
URL: https://github.com/apache/kafka/pull/14589#discussion_r1371818152
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -310,16 +313,22 @@ public CompletableFuture joinGroup(
wolfchimneyrock opened a new pull request, #14635:
URL: https://github.com/apache/kafka/pull/14635
KIP-848 introduced this check, but we have seen since upgrading to broker
3.4 with both Sarama and Librdkafka clients when issuing LeaveGroup and getting
an error, the single member gets lost
divijvaidya commented on PR #14242:
URL: https://github.com/apache/kafka/pull/14242#issuecomment-1779404361
> If we ignore producer-state-flush failure here, recovery-point might be
incremented even with stale on-disk producer state snapshot. So, in case of
restart after power failure, the
dajac commented on code in PR #14537:
URL: https://github.com/apache/kafka/pull/14537#discussion_r1371838869
##
core/src/test/scala/unit/kafka/server/DescribeGroupsRequestTest.scala:
##
@@ -0,0 +1,118 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
rondagostino commented on code in PR #14290:
URL: https://github.com/apache/kafka/pull/14290#discussion_r1371865719
##
metadata/src/main/java/org/apache/kafka/controller/PartitionChangeBuilder.java:
##
@@ -54,6 +54,7 @@ public static boolean
changeRecordIsNoOp(PartitionChangeRe
divijvaidya commented on PR #14410:
URL: https://github.com/apache/kafka/pull/14410#issuecomment-1779407230
> @divijvaidya Do you have cycles to review this?
Sure, I can get to this before the end this week.
--
This is an automated message from the Apache Git Service.
To respond to
soarez commented on code in PR #14628:
URL: https://github.com/apache/kafka/pull/14628#discussion_r1371749943
##
metadata/src/main/java/org/apache/kafka/metadata/properties/MetaProperties.java:
##
@@ -0,0 +1,266 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under o
dajac commented on PR #14635:
URL: https://github.com/apache/kafka/pull/14635#issuecomment-1779417281
@wolfchimneyrock Thanks for the PR. I am not to fully understand the issue
yet. Could you please elaborate a bit more about the condition leading to it?
--
This is an automated message fr
wolfchimneyrock commented on PR #14635:
URL: https://github.com/apache/kafka/pull/14635#issuecomment-1779425711
> @wolfchimneyrock Thanks for the PR. I am not to fully understand the issue
yet. Could you please elaborate a bit more about the condition leading to it?
there is more cont
Owen-CH-Leung opened a new pull request, #14636:
URL: https://github.com/apache/kafka/pull/14636
As per the request in
[KAFKA-15200](https://issues.apache.org/jira/browse/KAFKA-15200), This PR adds
pre-requitsite-check in the `release.py` before the release process begins
### Committ
[
https://issues.apache.org/jira/browse/KAFKA-15200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779537#comment-17779537
]
Owen C.H. Leung commented on KAFKA-15200:
-
[~divijvaidya] I've created PR for th
wolfchimneyrock commented on PR #14635:
URL: https://github.com/apache/kafka/pull/14635#issuecomment-1779439685
I'm not sure I can elaborate on what the underlying error response that
would have been sent with the LeaveGroup is, since the current code raises
that exception without printing
iamlockon opened a new pull request, #14637:
URL: https://github.com/apache/kafka/pull/14637
*More detailed description of your change,
Originally the assert and stub statements are not verifying correctly, so
`assertEquals` will always be true.
I have checked the whole file and fixed
Apoorv Mittal created KAFKA-15683:
-
Summary: Delete subscription from metadata when all configs are
deleted
Key: KAFKA-15683
URL: https://issues.apache.org/jira/browse/KAFKA-15683
Project: Kafka
Apoorv Mittal created KAFKA-15684:
-
Summary: Add support to describe all subscriptions through utility
Key: KAFKA-15684
URL: https://issues.apache.org/jira/browse/KAFKA-15684
Project: Kafka
I
wolfchimneyrock commented on PR #14635:
URL: https://github.com/apache/kafka/pull/14635#issuecomment-1779515287
Here is a broker trace:
```
[2023-10-24 01:17:17,214] ERROR [KafkaApi-28598] Unexpected error handling
request RequestHeader(apiKey=LEAVE_GROUP, apiVersion=1, clientId=REDACT
msn-tldr commented on PR #14564:
URL: https://github.com/apache/kafka/pull/14564#issuecomment-1779551983
@AndrewJSchofield & @kirktrue addressed the feedback so far!
thanks for the reviews.
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
pprovenzano commented on PR #14578:
URL: https://github.com/apache/kafka/pull/14578#issuecomment-1779628602
Closing this PR in favor of https://github.com/apache/kafka/pull/14628
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
pprovenzano closed pull request #14578: KAFKA-15633: Fix overwrite of
meta.properties at startup to handle JBOD.
URL: https://github.com/apache/kafka/pull/14578
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
junrao commented on code in PR #14603:
URL: https://github.com/apache/kafka/pull/14603#discussion_r1372017036
##
storage/src/main/java/org/apache/kafka/storage/internals/checkpoint/CleanShutdownFileHandler.java:
##
@@ -73,10 +77,8 @@ void write(long brokerEpoch, int version) thr
C0urante commented on PR #14630:
URL: https://github.com/apache/kafka/pull/14630#issuecomment-1779644800
@kumarpritam863 is this the same as
https://github.com/apache/kafka/pull/12622 and
https://issues.apache.org/jira/browse/KAFKA-14220?
--
This is an automated message from the Apache G
divijvaidya commented on code in PR #14625:
URL: https://github.com/apache/kafka/pull/14625#discussion_r1372035225
##
clients/src/test/java/org/apache/kafka/common/record/DefaultRecordBatchTest.java:
##
@@ -63,15 +61,9 @@
import static org.mockito.Mockito.when;
public class
apoorvmittal10 commented on code in PR #14621:
URL: https://github.com/apache/kafka/pull/14621#discussion_r1372044581
##
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java:
##
@@ -2619,6 +2619,9 @@ private ConfigEntry.ConfigSource
configSource(DescribeCo
[
https://issues.apache.org/jira/browse/KAFKA-15564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779568#comment-17779568
]
Greg Harris commented on KAFKA-15564:
-
[~hemanthsavasere] Were you able to work arou
apoorvmittal10 commented on code in PR #14621:
URL: https://github.com/apache/kafka/pull/14621#discussion_r1372045362
##
core/src/main/scala/kafka/metrics/ClientMetricsConfig.scala:
##
@@ -0,0 +1,141 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
apoorvmittal10 commented on code in PR #14621:
URL: https://github.com/apache/kafka/pull/14621#discussion_r1372046033
##
core/src/main/scala/kafka/metrics/ClientMetricsMetadata.scala:
##
@@ -0,0 +1,130 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or mor
apoorvmittal10 commented on code in PR #14621:
URL: https://github.com/apache/kafka/pull/14621#discussion_r1372047546
##
core/src/main/scala/kafka/server/ZkConfigManager.scala:
##
@@ -38,7 +38,8 @@ object ConfigType {
val User = "users"
val Broker = "brokers"
val Ip = "
apoorvmittal10 commented on code in PR #14621:
URL: https://github.com/apache/kafka/pull/14621#discussion_r1372045729
##
core/src/main/scala/kafka/metrics/ClientMetricsMetadata.scala:
##
@@ -0,0 +1,130 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or mor
apoorvmittal10 commented on code in PR #14621:
URL: https://github.com/apache/kafka/pull/14621#discussion_r1372046737
##
core/src/main/scala/kafka/metrics/ClientMetricsMetadata.scala:
##
@@ -0,0 +1,130 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or mor
apoorvmittal10 commented on code in PR #14621:
URL: https://github.com/apache/kafka/pull/14621#discussion_r1372047782
##
core/src/test/scala/kafka/metrics/ClientMetricsTestUtils.scala:
##
@@ -0,0 +1,39 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or mor
kirktrue closed pull request #14357: KAFKA-15276: Implement partition
assignment reconciliation
URL: https://github.com/apache/kafka/pull/14357
--
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 sp
1 - 100 of 202 matches
Mail list logo