Mickael Maison created KAFKA-16153:
--
Summary: kraft_upgrade_test system test is broken
Key: KAFKA-16153
URL: https://issues.apache.org/jira/browse/KAFKA-16153
Project: Kafka
Issue Type: Bug
mimaison commented on code in PR #15159:
URL: https://github.com/apache/kafka/pull/15159#discussion_r1454953584
##
checkstyle/import-control-core.xml:
##
@@ -94,6 +94,7 @@
+
Review Comment:
I think we can remove that line too
--
This is an automated m
satishd closed pull request #15209: MINOR Removed unused CommittedOffsetsFile
class.
URL: https://github.com/apache/kafka/pull/15209
--
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 comm
AndrewJSchofield commented on code in PR #15000:
URL: https://github.com/apache/kafka/pull/15000#discussion_r1455084554
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/CommitRequestManagerTest.java:
##
@@ -367,6 +372,42 @@ public void testAutocommitEnsureOnl
[
https://issues.apache.org/jira/browse/KAFKA-4759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807680#comment-17807680
]
Szymon Scharmach commented on KAFKA-4759:
-
Updated PR is ready: [https://github.c
DL1231 opened a new pull request, #15211:
URL: https://github.com/apache/kafka/pull/15211
While using —list —state the current accepted values correspond to the
classic group type states.
This PR include support for the new group type states.
### Committer Checklist (excluded from
DL1231 commented on PR #15211:
URL: https://github.com/apache/kafka/pull/15211#issuecomment-1895572781
@rreddy-22 PTAL.
--
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
[
https://issues.apache.org/jira/browse/KAFKA-16147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-16147:
---
Assignee: David Jacot
> Partition is assigned to two members at the same time
> ---
dajac opened a new pull request, #15212:
URL: https://github.com/apache/kafka/pull/15212
We had a case where a partition got assigned to two members and we found a
bug in the partition epochs bookkeeping. Basically, when a member has a
partition pending revocation re-assigned to him before
DL1231 commented on PR #15067:
URL: https://github.com/apache/kafka/pull/15067#issuecomment-1895664514
@dajac, PTAL, thanks in advance.
--
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
Christo Lolov created KAFKA-16154:
-
Summary: Make broker changes to return an offset for
LATEST_TIERED_TIMESTAMP
Key: KAFKA-16154
URL: https://issues.apache.org/jira/browse/KAFKA-16154
Project: Kafka
clolov opened a new pull request, #15213:
URL: https://github.com/apache/kafka/pull/15213
### Summary
This is the first part of the implementation of
[KIP-1005](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1005%3A+Expose+EarliestLocalOffset+and+TieredOffset)
The purpos
clolov commented on code in PR #15213:
URL: https://github.com/apache/kafka/pull/15213#discussion_r1455525955
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -1300,18 +1303,27 @@ class UnifiedLog(@volatile var logStartOffset: Long,
} else if (targetTimestamp ==
Lucas Brutschy created KAFKA-16155:
--
Summary: Investigate testAutoCommitIntercept
Key: KAFKA-16155
URL: https://issues.apache.org/jira/browse/KAFKA-16155
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-16155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy updated KAFKA-16155:
---
Description:
Even with KAFKA-15942, the test PlaintextConsumerTest.testAutoCommitIntercept
OmniaGM commented on code in PR #15159:
URL: https://github.com/apache/kafka/pull/15159#discussion_r1455645909
##
checkstyle/import-control-core.xml:
##
@@ -94,6 +94,7 @@
+
Review Comment:
remove it
--
This is an automated message from the Apache Git
lucasbru commented on code in PR #15000:
URL: https://github.com/apache/kafka/pull/15000#discussion_r1455660640
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/CommitRequestManagerTest.java:
##
@@ -367,6 +372,42 @@ public void testAutocommitEnsureOnlyOneInfl
lucasbru commented on code in PR #15000:
URL: https://github.com/apache/kafka/pull/15000#discussion_r1455670090
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -93,9 +94,11 @@ public CommitRequestManager(
final S
lucasbru commented on code in PR #15000:
URL: https://github.com/apache/kafka/pull/15000#discussion_r1455660640
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/CommitRequestManagerTest.java:
##
@@ -367,6 +372,42 @@ public void testAutocommitEnsureOnlyOneInfl
lucasbru commented on code in PR #15000:
URL: https://github.com/apache/kafka/pull/15000#discussion_r1455660640
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/CommitRequestManagerTest.java:
##
@@ -367,6 +372,42 @@ public void testAutocommitEnsureOnlyOneInfl
pprovenzano commented on code in PR #15197:
URL: https://github.com/apache/kafka/pull/15197#discussion_r1455684322
##
metadata/src/main/java/org/apache/kafka/image/FeaturesImage.java:
##
@@ -46,6 +46,18 @@ public final class FeaturesImage {
ZkMigrationState.NONE
);
lucasbru merged PR #15204:
URL: https://github.com/apache/kafka/pull/15204
--
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.apache
Lianet Magrans created KAFKA-16156:
--
Summary: System test failing on endOffsets with negative timestamps
Key: KAFKA-16156
URL: https://issues.apache.org/jira/browse/KAFKA-16156
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16156:
---
Description:
TransactionalMessageCopier run with 3.7 new consumer fails with "Invalid
negat
[
https://issues.apache.org/jira/browse/KAFKA-16156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16156:
---
Summary: System test failing for new consumer on endOffsets with negative
timestamps (was:
lucasbru commented on code in PR #15000:
URL: https://github.com/apache/kafka/pull/15000#discussion_r1455787900
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java:
##
@@ -844,6 +849,54 @@ public void testWakeupCommitted() {
lucasbru commented on code in PR #15000:
URL: https://github.com/apache/kafka/pull/15000#discussion_r1455790243
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1902,65 +1912,14 @@ private void maybeThrowFencedInstanceException
[
https://issues.apache.org/jira/browse/KAFKA-16134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807767#comment-17807767
]
Lianet Magrans commented on KAFKA-16134:
Might be related
> kafka.api.Plaintext
[
https://issues.apache.org/jira/browse/KAFKA-16134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807767#comment-17807767
]
Lianet Magrans edited comment on KAFKA-16134 at 1/17/24 3:21 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-16150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807772#comment-17807772
]
Lianet Magrans commented on KAFKA-16150:
[~kirktrue] this seems the same as
htt
[
https://issues.apache.org/jira/browse/KAFKA-16151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807773#comment-17807773
]
Lianet Magrans commented on KAFKA-16151:
[~kirktrue] isn't this the same as
htt
AndrewJSchofield opened a new pull request, #15214:
URL: https://github.com/apache/kafka/pull/15214
The `ListClientMetricsResourcesResponse` definition is missing several
`"about"` descriptions. The main effect of this is that the Kafka protocol
documentation misses the descriptions of thes
[
https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15538:
---
Description:
When using subscribe with a java regex (Pattern), we need to resolve it on the
[
https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807783#comment-17807783
]
Lianet Magrans commented on KAFKA-15538:
Hey [~phuctran], you're right that the
kirktrue closed pull request #15206: KAFKA-16104: Enable additional
PlaintextConsumerTest tests for new consumer
URL: https://github.com/apache/kafka/pull/15206
--
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
kirktrue commented on PR #15206:
URL: https://github.com/apache/kafka/pull/15206#issuecomment-1896159822
Closing and reopening to kick off another test run
--
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
Gaurav Narula created KAFKA-16157:
-
Summary: Topic recreation with offline disk doesn't update
leadership/shrink ISR correctly
Key: KAFKA-16157
URL: https://issues.apache.org/jira/browse/KAFKA-16157
P
[
https://issues.apache.org/jira/browse/KAFKA-16157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gaurav Narula updated KAFKA-16157:
--
Attachment: broker.log
broker.log.1
broker.log.2
mimaison commented on code in PR #14856:
URL: https://github.com/apache/kafka/pull/14856#discussion_r1456011084
##
tools/src/main/java/org/apache/kafka/tools/consumergroup/PartitionAssignmentState.java:
##
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/KAFKA-16157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807814#comment-17807814
]
Mickael Maison commented on KAFKA-16157:
Did you hit this issue while testing 3.
philipnee commented on code in PR #15000:
URL: https://github.com/apache/kafka/pull/15000#discussion_r1456105594
##
core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala:
##
@@ -1336,8 +1336,9 @@ class PlaintextConsumerTest extends BaseConsumerTest {
MockPro
[
https://issues.apache.org/jira/browse/KAFKA-16157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Proven Provenzano updated KAFKA-16157:
--
Priority: Blocker (was: Major)
> Topic recreation with offline disk doesn't update le
[
https://issues.apache.org/jira/browse/KAFKA-16157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gaurav Narula updated KAFKA-16157:
--
Description:
In a cluster with 4 brokers, `broker-1..broker-4` with 2 disks `d1` and `d2` in
philipnee commented on PR #15210:
URL: https://github.com/apache/kafka/pull/15210#issuecomment-1896275067
@lucasbru - Would you have time to review this? Seems like the failed tests
aren't necessary related.
--
This is an automated message from the Apache Git Service.
To respond to the me
lianetm opened a new pull request, #15215:
URL: https://github.com/apache/kafka/pull/15215
This ensures that no records are fetched in the background thread while the
onPartitionsAssigned callback completes running in the Application thread. This
is achieved by pausing the partitions before
[
https://issues.apache.org/jira/browse/KAFKA-16157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-16157:
---
Affects Version/s: 3.7.0
(was: 3.7.1)
> Topic recreation with off
jolshan commented on code in PR #15176:
URL: https://github.com/apache/kafka/pull/15176#discussion_r1456228457
##
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala:
##
@@ -935,8 +935,9 @@ private[group] class GroupCoordinator(
producerId,
p
jolshan commented on code in PR #14856:
URL: https://github.com/apache/kafka/pull/14856#discussion_r1456242441
##
tools/src/main/java/org/apache/kafka/tools/consumergroup/ConsumerGroupCommandOptions.java:
##
@@ -0,0 +1,263 @@
+/*
Review Comment:
Is the tools/consumergroup a
jolshan commented on PR #14856:
URL: https://github.com/apache/kafka/pull/14856#issuecomment-1896365557
Did we want to delete the old files in this PR or a follow up?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
kirktrue commented on PR #14818:
URL: https://github.com/apache/kafka/pull/14818#issuecomment-1896409297
@jcme—Can you trigger a rebuild of the CI job? It looks like the last run
didn't work.
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
philipnee opened a new pull request, #15216:
URL: https://github.com/apache/kafka/pull/15216
(no comment)
--
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-
jolshan commented on code in PR #15212:
URL: https://github.com/apache/kafka/pull/15212#discussion_r1456314640
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroup.java:
##
@@ -861,19 +861,9 @@ private void maybeUpdatePartitionEpoch(
pprovenzano commented on PR #15197:
URL: https://github.com/apache/kafka/pull/15197#issuecomment-1896448532
Test failures are not related.
--
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
junrao commented on code in PR #15190:
URL: https://github.com/apache/kafka/pull/15190#discussion_r1456303419
##
core/src/main/scala/kafka/network/SocketServer.scala:
##
@@ -1140,9 +1141,9 @@ private[kafka] class Processor(
expiredConnectionsKilledCount.record(n
gharris1727 commented on PR #14729:
URL: https://github.com/apache/kafka/pull/14729#issuecomment-1896468099
@chia7712 @showuon @mimaison Are any of you able to review this resource
leak fix? Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
gharris1727 closed pull request #14762: KAFKA-15826: Close consumer when sink
task is cancelled
URL: https://github.com/apache/kafka/pull/14762
--
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
gharris1727 commented on PR #14762:
URL: https://github.com/apache/kafka/pull/14762#issuecomment-1896474948
I think due to the locking concerns I raised earlier, and that we can
resolve this resource leak in our tests, this PR is not viable to merge. We can
revisit this in the future if the
[
https://issues.apache.org/jira/browse/KAFKA-16156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807858#comment-17807858
]
Justine Olshan commented on KAFKA-16156:
The transactional copier is pretty old.
[
https://issues.apache.org/jira/browse/KAFKA-16116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16116:
--
Parent: (was: KAFKA-14246)
Issue Type: Improvement (was: Sub-task)
> AsyncKafkaConsumer:
[
https://issues.apache.org/jira/browse/KAFKA-15878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807866#comment-17807866
]
Kirk True commented on KAFKA-15878:
---
[~philomathanuj]—for this to work, I assume the u
[
https://issues.apache.org/jira/browse/KAFKA-16150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16150.
---
Resolution: Duplicate
> Fix PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe
> -
[
https://issues.apache.org/jira/browse/KAFKA-16151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16151.
---
Resolution: Duplicate
> Fix PlaintextConsumerTest.testPerPartitionLeadMetricsCleanUpWithSubscribe
>
cmccabe commented on code in PR #14389:
URL: https://github.com/apache/kafka/pull/14389#discussion_r1456440526
##
tools/src/main/java/org/apache/kafka/tools/SchemaChecker/MetadataSchemaChecker.java:
##
@@ -0,0 +1,347 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
cmccabe commented on code in PR #14389:
URL: https://github.com/apache/kafka/pull/14389#discussion_r1456442184
##
tools/src/main/java/org/apache/kafka/tools/SchemaChecker/MetadataSchemaChecker.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
cmccabe commented on code in PR #14389:
URL: https://github.com/apache/kafka/pull/14389#discussion_r1456441308
##
tools/src/main/java/org/apache/kafka/tools/SchemaChecker/MetadataSchemaChecker.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
cmccabe commented on code in PR #14389:
URL: https://github.com/apache/kafka/pull/14389#discussion_r1456447370
##
tools/src/main/java/org/apache/kafka/tools/SchemaChecker/MetadataSchemaChecker.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
cmccabe commented on code in PR #14389:
URL: https://github.com/apache/kafka/pull/14389#discussion_r1456448643
##
tools/src/main/java/org/apache/kafka/tools/SchemaChecker/MetadataSchemaChecker.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
cmccabe commented on code in PR #14389:
URL: https://github.com/apache/kafka/pull/14389#discussion_r1456448973
##
tools/src/main/java/org/apache/kafka/tools/SchemaChecker/MetadataSchemaChecker.java:
##
@@ -0,0 +1,347 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
cmccabe commented on code in PR #14389:
URL: https://github.com/apache/kafka/pull/14389#discussion_r1456451709
##
tools/src/main/java/org/apache/kafka/tools/SchemaChecker/MetadataSchemaChecker.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
[
https://issues.apache.org/jira/browse/KAFKA-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-16141:
---
Assignee: Matthias J. Sax (was: Almog Gavra)
> StreamsStandbyTask##test_standby_ta
[
https://issues.apache.org/jira/browse/KAFKA-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807890#comment-17807890
]
Matthias J. Sax commented on KAFKA-16141:
-
After discussion with Almog (and test
mjsax opened a new pull request, #15217:
URL: https://github.com/apache/kafka/pull/15217
KAFKA-15629 added `TimestampedByteStore` interface to
`KeyValueToTimestampedKeyValueByteStoreAdapter` which break the restore code
path and thus some system tests.
This PR reverts this change for
mjsax commented on PR #15217:
URL: https://github.com/apache/kafka/pull/15217#issuecomment-1896696469
\cc @agavra @stanislavkozlovski
--
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
mjsax commented on code in PR #15217:
URL: https://github.com/apache/kafka/pull/15217#discussion_r1456485535
##
streams/src/main/java/org/apache/kafka/streams/state/internals/StoreQueryUtils.java:
##
@@ -422,6 +423,16 @@ public static Function
getDeserializeValue(final StateSe
Matthias J. Sax created KAFKA-16158:
---
Summary: Cleanup usage of `TimestampedBytesStore` interface
Key: KAFKA-16158
URL: https://issues.apache.org/jira/browse/KAFKA-16158
Project: Kafka
Issu
[
https://issues.apache.org/jira/browse/KAFKA-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807890#comment-17807890
]
Matthias J. Sax edited comment on KAFKA-16141 at 1/17/24 9:15 PM:
mjsax commented on PR #15217:
URL: https://github.com/apache/kafka/pull/15217#issuecomment-1896752852
Triggered a system test run:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/6035/
--
This is an automated message from the Apache Git Service.
To respond to the message
anurag-harness opened a new pull request, #15218:
URL: https://github.com/apache/kafka/pull/15218
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of
jeffkbkim commented on PR #15212:
URL: https://github.com/apache/kafka/pull/15212#issuecomment-1896786496
> when a member has a partition pending revocation re-assigned to him before
the revocation is completed, the partition epoch is lost
to confirm, the `previousMemberEpoch=11` shou
[
https://issues.apache.org/jira/browse/KAFKA-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16141:
Issue Type: Bug (was: Test)
> StreamsStandbyTask##test_standby_tasks_rebalanceArguments:{
mjsax merged PR #15207:
URL: https://github.com/apache/kafka/pull/15207
--
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.apache.or
mjsax commented on PR #15207:
URL: https://github.com/apache/kafka/pull/15207#issuecomment-1896826978
Merged to `trunk` and cherry-picked to `3.7` branch.
--
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 t
[
https://issues.apache.org/jira/browse/KAFKA-16139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-16139.
-
Fix Version/s: 3.7.0
3.6.1
Resolution: Fixed
> StreamsUpgradeT
nizhikov commented on code in PR #14856:
URL: https://github.com/apache/kafka/pull/14856#discussion_r1456518422
##
tools/src/main/java/org/apache/kafka/tools/consumergroup/PartitionAssignmentState.java:
##
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
nizhikov commented on code in PR #14856:
URL: https://github.com/apache/kafka/pull/14856#discussion_r1456521165
##
tools/src/main/java/org/apache/kafka/tools/consumergroup/ConsumerGroupCommandOptions.java:
##
@@ -0,0 +1,263 @@
+/*
+ * Licensed to the Apache Software Foundation (
mjsax commented on code in PR #15148:
URL: https://github.com/apache/kafka/pull/15148#discussion_r1456522509
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -715,15 +716,22 @@ private Optional>
createPushRequest(ClientTel
nizhikov commented on code in PR #14856:
URL: https://github.com/apache/kafka/pull/14856#discussion_r1456523688
##
tools/src/main/java/org/apache/kafka/tools/consumergroup/ConsumerGroupCommandOptions.java:
##
@@ -0,0 +1,263 @@
+/*
+ * Licensed to the Apache Software Foundation (
mjsax merged PR #15148:
URL: https://github.com/apache/kafka/pull/15148
--
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.apache.or
jeffkbkim commented on code in PR #15196:
URL: https://github.com/apache/kafka/pull/15196#discussion_r1456526190
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -1098,30 +1054,36 @@ private static boolean isGroupIdNotEmpt
nizhikov commented on PR #14856:
URL: https://github.com/apache/kafka/pull/14856#issuecomment-1896962207
@jolshan
> Did we want to delete the old files in this PR or a follow up?
For the previous command we remove old files only when command was merged
1. Reassign case
nizhikov commented on code in PR #14856:
URL: https://github.com/apache/kafka/pull/14856#discussion_r1456530381
##
tools/src/main/java/org/apache/kafka/tools/consumergroup/ConsumerGroupCommandOptions.java:
##
@@ -0,0 +1,263 @@
+/*
Review Comment:
> Is the tools/consumergroup
jolshan commented on code in PR #14856:
URL: https://github.com/apache/kafka/pull/14856#discussion_r1456536862
##
tools/src/main/java/org/apache/kafka/tools/consumergroup/ConsumerGroupCommandOptions.java:
##
@@ -0,0 +1,263 @@
+/*
Review Comment:
I wasn't sure if we wanted to
cmccabe merged PR #15197:
URL: https://github.com/apache/kafka/pull/15197
--
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.apache.
Philip Nee created KAFKA-16159:
--
Summary: Prune excessive logging from Telemetry Reporter
Key: KAFKA-16159
URL: https://issues.apache.org/jira/browse/KAFKA-16159
Project: Kafka
Issue Type: Task
nizhikov commented on code in PR #14856:
URL: https://github.com/apache/kafka/pull/14856#discussion_r1456546534
##
tools/src/main/java/org/apache/kafka/tools/consumergroup/ConsumerGroupCommandOptions.java:
##
@@ -0,0 +1,263 @@
+/*
Review Comment:
> I think when we have had t
[
https://issues.apache.org/jira/browse/KAFKA-16159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-16159:
---
Labels: logging (was: )
> Prune excessive logging from Telemetry Reporter
> ---
[
https://issues.apache.org/jira/browse/KAFKA-16159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-16159:
---
Labels: consumer logging (was: logging)
> Prune excessive logging from Telemetry Reporter
> ---
[
https://issues.apache.org/jira/browse/KAFKA-16159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-16159:
---
Fix Version/s: 3.8.0
> Prune excessive logging from Telemetry Reporter
> ---
[
https://issues.apache.org/jira/browse/KAFKA-16131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-16131.
--
Resolution: Fixed
> Repeated UnsupportedVersionException logged when running Kafka 3.7.0-RC2
[
https://issues.apache.org/jira/browse/KAFKA-16159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-16159:
---
Description:
While running system tests locally, I've noticed excessive logging of the
Telemtry Rep
1 - 100 of 157 matches
Mail list logo
