Justinwins commented on PR #12350:
URL: https://github.com/apache/kafka/pull/12350#issuecomment-1212684275
@mimaison will you pls merge this simple issue ?
--
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
niket-goel opened a new pull request, #12508:
URL: https://github.com/apache/kafka/pull/12508
This commit adds in the implementation for two new fields:
* LastFetchTimestamp
* LastCaughtUpTimestamp
as they are described in KIP-836
--
This is an automated message from the Apache
hachikuji merged PR #12506:
URL: https://github.com/apache/kafka/pull/12506
--
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:
[
https://issues.apache.org/jira/browse/KAFKA-13986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-13986.
-
Fix Version/s: 3.3.0
Resolution: Fixed
> DescribeQuorum does not return the
[
https://issues.apache.org/jira/browse/KAFKA-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prime Minister of Funhavistan updated KAFKA-14164:
--
Description:
Step 1: On a server running kafka using the
[
https://issues.apache.org/jira/browse/KAFKA-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prime Minister of Funhavistan updated KAFKA-14164:
--
Description:
Step 1: On a server running kafka using the
[
https://issues.apache.org/jira/browse/KAFKA-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prime Minister of Funhavistan updated KAFKA-14164:
--
Description:
Step 1: On a server running kafka using the
[
https://issues.apache.org/jira/browse/KAFKA-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prime Minister of Funhavistan updated KAFKA-14164:
--
Description:
Step 1: On a server running kafka using the
[
https://issues.apache.org/jira/browse/KAFKA-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prime Minister of Funhavistan updated KAFKA-14164:
--
Description:
Step 1: On a server running kafka using the
[
https://issues.apache.org/jira/browse/KAFKA-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prime Minister of Funhavistan updated KAFKA-14164:
--
Description:
Step 1: On a server running kafka using the
hachikuji merged PR #12498:
URL: https://github.com/apache/kafka/pull/12498
--
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:
Prime Minister of Funhavistan created KAFKA-14164:
-
Summary: Enabling JMX on one Service Breaks kafka-run-class Shell
Script for All
Key: KAFKA-14164
URL:
[
https://issues.apache.org/jira/browse/KAFKA-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-14163.
-
Resolution: Workaround
> Build failing in streams-scala:compileScala due to zinc
hachikuji merged PR #12507:
URL: https://github.com/apache/kafka/pull/12507
--
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:
jsancio commented on code in PR #12274:
URL: https://github.com/apache/kafka/pull/12274#discussion_r943618096
##
raft/src/main/java/org/apache/kafka/raft/internals/FuturePurgatory.java:
##
@@ -56,7 +56,7 @@
CompletableFuture await(T threshold, long maxWaitTimeMs);
hachikuji commented on PR #12506:
URL: https://github.com/apache/kafka/pull/12506#issuecomment-1212307242
@jsancio Yeah, let's use the same jira for the kraft issue if that's ok with
you. Let me see if I can get a PR out today.
--
This is an automated message from the Apache Git Service.
hachikuji opened a new pull request, #12507:
URL: https://github.com/apache/kafka/pull/12507
Borrowing this workaround from @lbradstreet for the same problem.
Co-authored-by: Lucas Bradstreet
### Committer Checklist (excluded from commit message)
- [ ] Verify design and
[
https://issues.apache.org/jira/browse/KAFKA-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-14163:
Summary: Build failing in streams-scala:compileScala due to zinc compiler
cache (was:
dajac commented on code in PR #12506:
URL: https://github.com/apache/kafka/pull/12506#discussion_r943741675
##
core/src/main/scala/kafka/controller/KafkaController.scala:
##
@@ -2336,7 +2336,14 @@ class KafkaController(val config: KafkaConfig,
[
https://issues.apache.org/jira/browse/KAFKA-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-14163:
Description:
I have been seeing builds failing recently with the following error:
[
https://issues.apache.org/jira/browse/KAFKA-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-14163:
Description:
I have been seeing builds failing recently with the following error:
Jason Gustafson created KAFKA-14163:
---
Summary: Build failing in scala:compileScala due to zinc compiler
cache
Key: KAFKA-14163
URL: https://issues.apache.org/jira/browse/KAFKA-14163
Project: Kafka
jsancio commented on PR #12506:
URL: https://github.com/apache/kafka/pull/12506#issuecomment-1212271060
> but I believe the problem exists for kraft as well.
Are you planning to use the same Jira (KAFKA-14154 to track this? I assume
that the KRaft fix is also a blocker for 3.3.0.
hachikuji commented on PR #12506:
URL: https://github.com/apache/kafka/pull/12506#issuecomment-1212257796
One note: this patch fixes the problem for the zk controller, but I believe
the problem exists for kraft as well. I am thinking we can address that
separately with a slightly different
hachikuji commented on PR #12506:
URL: https://github.com/apache/kafka/pull/12506#issuecomment-1212250619
cc @jsancio @dajac
--
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
hachikuji opened a new pull request, #12506:
URL: https://github.com/apache/kafka/pull/12506
It is possible for the leader to send an `AlterPartition` request to a
zombie controller which includes either a partition or leader epoch which is
larger than what is found in the controller
hachikuji closed pull request #12499: KAFKA-14154; Ensure AlterPartition not
sent to stale controller
URL: https://github.com/apache/kafka/pull/12499
--
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
hachikuji commented on PR #12499:
URL: https://github.com/apache/kafka/pull/12499#issuecomment-1212226476
I am going to close this PR. On the one hand, it does not address the
problem for KRaft; on the other, we have thought of a simpler fix for the zk
controller, which I will open
mimaison commented on code in PR #12046:
URL: https://github.com/apache/kafka/pull/12046#discussion_r943688586
##
server-common/src/main/java/org/apache/kafka/server/metrics/KafkaYammerMetrics.java:
##
@@ -53,16 +72,21 @@ public static MetricsRegistry defaultRegistry() {
}
yashmayya commented on code in PR #12490:
URL: https://github.com/apache/kafka/pull/12490#discussion_r943666445
##
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java:
##
@@ -853,6 +853,9 @@ private void
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov updated KAFKA-14133:
--
Description:
{color:#DE350B}There are tests which use both PowerMock and EasyMock. I have
clolov commented on PR #12505:
URL: https://github.com/apache/kafka/pull/12505#issuecomment-1212166713
Tagging @mdedetrich @cadonna @ijuma for visibility and reviews :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
clolov commented on code in PR #12505:
URL: https://github.com/apache/kafka/pull/12505#discussion_r943639431
##
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilderTest.java:
##
@@ -126,27 +121,15 @@ public void
clolov commented on code in PR #12505:
URL: https://github.com/apache/kafka/pull/12505#discussion_r943639431
##
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilderTest.java:
##
@@ -126,27 +121,15 @@ public void
clolov opened a new pull request, #12505:
URL: https://github.com/apache/kafka/pull/12505
Batch 2 of the tests detailed in
https://issues.apache.org/jira/browse/KAFKA-14133 which use EasyMock and need
to be moved to Mockito.
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/KAFKA-14134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya reassigned KAFKA-14134:
--
Assignee: Yash Mayya
> Replace EasyMock with Mockito for WorkerConnectorTest
>
[
https://issues.apache.org/jira/browse/KAFKA-14147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya reassigned KAFKA-14147:
--
Assignee: Yash Mayya
> Some map objects in KafkaConfigBackingStore grow in size
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov updated KAFKA-14133:
--
Description:
{color:#DE350B}There are tests which use both PowerMock and EasyMock. I have
mimaison opened a new pull request, #12504:
URL: https://github.com/apache/kafka/pull/12504
@mumrah @cmccabe
It looks like a way to fix `DynamicBrokerReconfigurationTest` in 3.2 is to
backport
https://github.com/apache/kafka/commit/9c3f605fc78f297ecf5accdcdec18471c19cf7d6.
I think it
[
https://issues.apache.org/jira/browse/KAFKA-14162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya reassigned KAFKA-14162:
--
Assignee: Yash Mayya
> HoistField SMT should not return an immutable map for schemaless
jsancio commented on code in PR #12274:
URL: https://github.com/apache/kafka/pull/12274#discussion_r943606596
##
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java:
##
@@ -1382,7 +1383,6 @@ ControllerResult
processBrokerHeartbeat(
jsancio commented on PR #12274:
URL: https://github.com/apache/kafka/pull/12274#issuecomment-1212113291
@dengziming take a look at the tests failures. All of the failures in
`ClusterControlManagerTest` seems related to this change.
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov updated KAFKA-14133:
--
Description:
{color:#DE350B}There are tests which use both PowerMock and EasyMock. I have
chia7712 opened a new pull request, #12503:
URL: https://github.com/apache/kafka/pull/12503
We noticed this issue when appending value to
`leader.replication.throttled.replicas`. The default value is empty string, so
it produces `,0:0` rather than `0:0`. For another, parsing throttled
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov updated KAFKA-14133:
--
Description:
{color:#DE350B}There are tests which use both PowerMock and EasyMock. I have
[
https://issues.apache.org/jira/browse/KAFKA-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17578486#comment-17578486
]
Mickael Maison commented on KAFKA-14098:
This would be very valuable. When looking at metrics
dstelljes commented on PR #12295:
URL: https://github.com/apache/kafka/pull/12295#issuecomment-1212026332
Sorry for the wait on this—it looks like work to switch the test to Mockito
is in flight now, so I’ll hang tight for now and rebase once that lands.
I do have an account on the
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov updated KAFKA-14133:
--
Description:
{color:#DE350B}There are tests which use both PowerMock and EasyMock. I have
andymg3 commented on code in PR #12499:
URL: https://github.com/apache/kafka/pull/12499#discussion_r941967874
##
core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala:
##
@@ -364,15 +423,15 @@ class BrokerToControllerRequestThread(
}
override def
[
https://issues.apache.org/jira/browse/KAFKA-14161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen resolved KAFKA-14161.
---
Resolution: Not A Problem
> kafka-consumer-group.sh --list not list all consumer groups
>
[
https://issues.apache.org/jira/browse/KAFKA-14161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17578351#comment-17578351
]
Luke Chen commented on KAFKA-14161:
---
[~yandufeng] , you should check your consumer setting. Not every
tombentley commented on code in PR #12046:
URL: https://github.com/apache/kafka/pull/12046#discussion_r943247605
##
server-common/src/main/java/org/apache/kafka/server/metrics/KafkaYammerMetrics.java:
##
@@ -53,16 +72,21 @@ public static MetricsRegistry defaultRegistry() {
ashmeet13 commented on code in PR #12414:
URL: https://github.com/apache/kafka/pull/12414#discussion_r943241275
##
raft/src/main/java/org/apache/kafka/raft/ReplicatedCounter.java:
##
@@ -107,6 +107,8 @@ public synchronized void handleCommit(BatchReader
reader) {
}
ashmeet13 commented on code in PR #12414:
URL: https://github.com/apache/kafka/pull/12414#discussion_r943240735
##
core/src/main/scala/kafka/server/metadata/BrokerMetadataSnapshotter.scala:
##
@@ -59,11 +60,19 @@ class BrokerMetadataSnapshotter(
val writer =
tombentley commented on code in PR #12046:
URL: https://github.com/apache/kafka/pull/12046#discussion_r943234303
##
server-common/src/main/java/org/apache/kafka/server/metrics/KafkaYammerMetrics.java:
##
@@ -53,16 +72,21 @@ public static MetricsRegistry defaultRegistry() {
yashmayya commented on PR #12502:
URL: https://github.com/apache/kafka/pull/12502#issuecomment-1211696790
@C0urante another small PR for you to review whenever you get a chance?
Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
yashmayya opened a new pull request, #12502:
URL: https://github.com/apache/kafka/pull/12502
- https://issues.apache.org/jira/browse/KAFKA-14162
- The HoistField SMT currently returns an immutable map for schemaless keys
and values -
Yash Mayya created KAFKA-14162:
--
Summary: HoistField SMT should not return an immutable map for
schemaless key/value
Key: KAFKA-14162
URL: https://issues.apache.org/jira/browse/KAFKA-14162
Project:
showuon commented on code in PR #12392:
URL: https://github.com/apache/kafka/pull/12392#discussion_r943219606
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -2594,27 +2596,20 @@ public void testDropCommitOnBatchExpiry()
showuon commented on PR #12500:
URL: https://github.com/apache/kafka/pull/12500#issuecomment-1211653244
Triggering another jenkins build to make sure it passes the tests.
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/view/change-requests/job/PR-12500/2/
--
This is an automated
yandufeng created KAFKA-14161:
-
Summary: kafka-consumer-group.sh --list not list all consumer
groups
Key: KAFKA-14161
URL: https://issues.apache.org/jira/browse/KAFKA-14161
Project: Kafka
Issue
dengziming commented on code in PR #12274:
URL: https://github.com/apache/kafka/pull/12274#discussion_r943173917
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1305,12 +1305,11 @@ private void handleFeatureControlChange() {
}
}
clolov commented on PR #11792:
URL: https://github.com/apache/kafka/pull/11792#issuecomment-1211589682
Okay @dplavcic! Thanks both for picking it up and for letting us know :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
ahuang98 commented on code in PR #12479:
URL: https://github.com/apache/kafka/pull/12479#discussion_r943125682
##
core/src/test/scala/unit/kafka/admin/DeleteTopicTest.scala:
##
@@ -45,103 +59,122 @@ class DeleteTopicTest extends QuorumTestHarness {
@AfterEach
override
64 matches
Mail list logo
