dengziming commented on PR #12274:
URL: https://github.com/apache/kafka/pull/12274#issuecomment-1212769383
Thank you for your good suggestions, @jsancio , I have resolved them.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
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 Gi
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: jira-unsubscr...@kafka.apach
[
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 obser
[
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 kafka
[
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 kafka
[
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 kafka
[
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 kafka
[
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 kafka
[
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 kafka
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: jira-unsubscr...@kafka.apach
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/KAF
[
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 compile
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: jira-unsubscr...@kafka.apach
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 impl
[
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: Bui
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,
controllerContext.partitionL
[
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:
{code
[
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:
{code:ja
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 comment.
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 contex
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 shortly.
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 processConnectorConfigRecord(String
[
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
put
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 t
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 shouldThrowNullPointerIfInnerIsNull(
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 shouldThrowNullPointerIfInnerIsNull(
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.
To
[
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 monotonically
[
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
put
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 m
[
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 key/v
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(
heartbe
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 Servi
[
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
put
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 repli
[
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
put
[
https://issues.apache.org/jira/browse/KAFKA-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578486#comment-17578486
]
Mickael Maison commented on KAFKA-14098:
This would be very valuable. When looki
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 AS
[
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
put
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 doWork
[
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&focusedCommentId=17578351#comment-17578351
]
Luke Chen commented on KAFKA-14161:
---
[~yandufeng] , you should check your consumer set
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 = writerBuilder
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 t
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 -
https://github.com/apache/kafka/blob/22007fba7c7346c54
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: Kafka
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() th
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 me
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() {
}
}
63 matches
Mail list logo