mingdaoy commented on code in PR #19025:
URL: https://github.com/apache/kafka/pull/19025#discussion_r1974658273
##
README.md:
##
@@ -75,6 +76,7 @@ Retries are disabled by default, but you can set
maxTestRetryFailures and maxTes
The following example declares -PmaxTestRetries=1
chia7712 commented on code in PR #18449:
URL: https://github.com/apache/kafka/pull/18449#discussion_r1974425642
##
.github/workflows/README.md:
##
@@ -133,4 +133,47 @@ Composite actions are a convenient way to reuse build
logic, but they have
some limitations.
- Cannot run
DL1231 opened a new pull request, #19055:
URL: https://github.com/apache/kafka/pull/19055
1、Client support for TopicAuthException in DescribeShareGroup and HB path
2、ShareConsumerImpl#sendAcknowledgementsAndLeaveGroup swallow
TopicAuthorizationException and GroupAuthorizationException
github-actions[bot] commented on PR #16779:
URL: https://github.com/apache/kafka/pull/16779#issuecomment-2689641095
This PR has been closed since it has not had any activity in 120 days. If
you feel like this
was a mistake, or you would like to continue working on it, please feel free
to
github-actions[bot] commented on PR #17324:
URL: https://github.com/apache/kafka/pull/17324#issuecomment-2689641143
This PR has been closed since it has not had any activity in 120 days. If
you feel like this
was a mistake, or you would like to continue working on it, please feel free
to
github-actions[bot] commented on PR #17493:
URL: https://github.com/apache/kafka/pull/17493#issuecomment-2689641187
This PR has been closed since it has not had any activity in 120 days. If
you feel like this
was a mistake, or you would like to continue working on it, please feel free
to
github-actions[bot] closed pull request #17493: KIP-1097 POC: error record
reporter API
URL: https://github.com/apache/kafka/pull/17493
--
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 c
gongxuanzhang opened a new pull request, #19054:
URL: https://github.com/apache/kafka/pull/19054
Move BaseKey, TxnKey, and UnknownKey to transaction-coordinator module
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
mjsax commented on code in PR #19052:
URL: https://github.com/apache/kafka/pull/19052#discussion_r1974831931
##
build.gradle:
##
@@ -51,7 +51,7 @@ ext {
gradleVersion = versions.gradle
minClientJavaVersion = 11
minNonClientJavaVersion = 17
- modulesNeedingJava11 = [":c
LoganZhuZzz commented on code in PR #19038:
URL: https://github.com/apache/kafka/pull/19038#discussion_r1974863681
##
server/src/main/java/org/apache/kafka/server/config/ServerConfigs.java:
##
@@ -52,7 +52,8 @@ public class ServerConfigs {
public static final String BACKGRO
github-actions[bot] closed pull request #17643: KAFKA-17627: ConfigProvider
TTLs do not restart Tasks
URL: https://github.com/apache/kafka/pull/17643
--
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
gongxuanzhang commented on PR #19056:
URL: https://github.com/apache/kafka/pull/19056#issuecomment-2689908338
Do we need to add an annotation to indicate that the thread is not
thread-safe?
@LoganZhuZzz @chia7712
--
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/KAFKA-18893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TaiJuWu reassigned KAFKA-18893:
---
Assignee: TaiJuWu
> Add support for ReplicaSelector
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-18898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-18898:
-
Affects Version/s: 4.0.0
> 4.0 Upgrade docs rendering below other versions
> ---
kevin-wu24 commented on code in PR #18987:
URL: https://github.com/apache/kafka/pull/18987#discussion_r1971722138
##
raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java:
##
@@ -1127,14 +1331,75 @@ private MajorityReachedHighWatermark(Cluster cluster) {
CalvinConfluent commented on PR #19044:
URL: https://github.com/apache/kafka/pull/19044#issuecomment-2688735295
@junrao I guess we need to add the ci-approved tag for the next test run.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
junrao commented on code in PR #18928:
URL: https://github.com/apache/kafka/pull/18928#discussion_r1974106703
##
clients/src/main/java/org/apache/kafka/clients/admin/DeleteGroupsResult.java:
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one o
chia7712 commented on code in PR #19052:
URL: https://github.com/apache/kafka/pull/19052#discussion_r1974350080
##
build.gradle:
##
@@ -51,7 +51,7 @@ ext {
gradleVersion = versions.gradle
minClientJavaVersion = 11
minNonClientJavaVersion = 17
- modulesNeedingJava11 = [
junrao commented on PR #18997:
URL: https://github.com/apache/kafka/pull/18997#issuecomment-2688594729
@FrankYang0529 : Thanks for the updated description. LGTM
@jsancio : +1 on cherry-pick this to 3.9 too.
--
This is an automated message from the Apache Git Service.
To respond to t
junrao merged PR #18997:
URL: https://github.com/apache/kafka/pull/18997
--
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.o
junrao commented on PR #18997:
URL: https://github.com/apache/kafka/pull/18997#issuecomment-2688642424
@jsancio : I merged the PR to trunk. Could you help cherry-pick it to 4.0
and 3.9?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
mimaison opened a new pull request, #19050:
URL: https://github.com/apache/kafka/pull/19050
This also adds metrics to StandardAuthorizer
--
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
[
https://issues.apache.org/jira/browse/KAFKA-18820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931235#comment-17931235
]
Vishal commented on KAFKA-18820:
Okay, thanks!
> CVE-2025-24970 [netty-handler]
> -
Mickael Maison created KAFKA-18894:
--
Summary: Add support for ConfigProvider
Key: KAFKA-18894
URL: https://issues.apache.org/jira/browse/KAFKA-18894
Project: Kafka
Issue Type: Sub-task
Mickael Maison created KAFKA-18891:
--
Summary: Add support for RemoteLogMetadataManager and
RemoteStorageManager
Key: KAFKA-18891
URL: https://issues.apache.org/jira/browse/KAFKA-18891
Project: Kafka
Mickael Maison created KAFKA-18893:
--
Summary: Add support for ReplicaSelector
Key: KAFKA-18893
URL: https://issues.apache.org/jira/browse/KAFKA-18893
Project: Kafka
Issue Type: Sub-task
Mickael Maison created KAFKA-18895:
--
Summary: Add support for AuthenticateCallbackHandler
Key: KAFKA-18895
URL: https://issues.apache.org/jira/browse/KAFKA-18895
Project: Kafka
Issue Type: S
Mickael Maison created KAFKA-18892:
--
Summary: Add support for ClientQuotaCallback
Key: KAFKA-18892
URL: https://issues.apache.org/jira/browse/KAFKA-18892
Project: Kafka
Issue Type: Sub-task
Mickael Maison created KAFKA-18896:
--
Summary: Add support for Login
Key: KAFKA-18896
URL: https://issues.apache.org/jira/browse/KAFKA-18896
Project: Kafka
Issue Type: Sub-task
Re
Mickael Maison created KAFKA-18897:
--
Summary: Add support for SslEngineFactory
Key: KAFKA-18897
URL: https://issues.apache.org/jira/browse/KAFKA-18897
Project: Kafka
Issue Type: Sub-task
gongxuanzhang commented on PR #19036:
URL: https://github.com/apache/kafka/pull/19036#issuecomment-2689565270
I think I have fixed it, but I’m not sure if I should delete the `Admin`’s
comment. PTAL @junrao @chia7712
--
This is an automated message from the Apache Git Service.
To respo
mingdaoy commented on code in PR #19025:
URL: https://github.com/apache/kafka/pull/19025#discussion_r1974675887
##
README.md:
##
@@ -42,6 +42,7 @@ Follow instructions in https://kafka.apache.org/quickstart
./gradlew test # runs both unit and integration tests
./gradle
github-actions[bot] closed pull request #17324: KAFKA-17348: Add custom produce
request parsers
URL: https://github.com/apache/kafka/pull/17324
--
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
github-actions[bot] commented on PR #9125:
URL: https://github.com/apache/kafka/pull/9125#issuecomment-2689641018
This PR is being marked as stale since it has not had any activity in 90
days. If you
would like to keep this PR alive, please leave a comment asking for a
review. If the PR
github-actions[bot] closed pull request #16779: KAFKA-17316: Standard
authorizer refactor
URL: https://github.com/apache/kafka/pull/16779
--
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
[
https://issues.apache.org/jira/browse/KAFKA-13022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang reassigned KAFKA-13022:
-
Assignee: PoAn Yang
> Optimize ClientQuotasImage#describe
> ---
mjsax commented on PR #19041:
URL: https://github.com/apache/kafka/pull/19041#issuecomment-2689866165
Thanks for the PR. Seems there is some confusion about this test...
First, the test was added like this 2 year ago and never modified. So it was
missed on the original PR review
http
LoganZhuZzz commented on PR #19056:
URL: https://github.com/apache/kafka/pull/19056#issuecomment-2689972128
> Do we need to add an annotation to indicate that the thread is not
thread-safe? @LoganZhuZzz @chia7712
Thanks for the feedback @gongxuanzhang ! Kafka already provides the
`@k
aminaaddd commented on PR #4948:
URL: https://github.com/apache/kafka/pull/4948#issuecomment-2689167200
| ERROR:root:Error:
KafkaError{code=UNKNOWN_TOPIC_OR_PART,val=3,str="Subscribed topic not
available: housing_topic: Broker: Unknown topic or partition"}
i have this problem and i d
[
https://issues.apache.org/jira/browse/KAFKA-18894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jhen-Yung Hsu reassigned KAFKA-18894:
-
Assignee: Jhen-Yung Hsu
> Add support for ConfigProvider
>
junrao commented on code in PR #19036:
URL: https://github.com/apache/kafka/pull/19036#discussion_r1974060328
##
clients/src/main/java/org/apache/kafka/clients/admin/AbortTransactionOptions.java:
##
@@ -16,9 +16,7 @@
*/
package org.apache.kafka.clients.admin;
-import org.ap
[
https://issues.apache.org/jira/browse/KAFKA-18891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TaiJuWu reassigned KAFKA-18891:
---
Assignee: TaiJuWu
> Add support for RemoteLogMetadataManager and RemoteStorageManager
> ---
gharris1727 commented on code in PR #19052:
URL: https://github.com/apache/kafka/pull/19052#discussion_r1974314924
##
docs/streams/developer-guide/datatypes.html:
##
@@ -156,11 +156,9 @@ Primitive and basic types
JSON
-The Kafka Streams code examples also includ
[
https://issues.apache.org/jira/browse/KAFKA-14488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TaiJuWu reassigned KAFKA-14488:
---
Assignee: TaiJuWu
> Move log layer tests to storage module
> --
chia7712 commented on code in PR #19025:
URL: https://github.com/apache/kafka/pull/19025#discussion_r1974442226
##
README.md:
##
@@ -75,6 +76,7 @@ Retries are disabled by default, but you can set
maxTestRetryFailures and maxTes
The following example declares -PmaxTestRetries=1
[
https://issues.apache.org/jira/browse/KAFKA-18891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931280#comment-17931280
]
Mickael Maison commented on KAFKA-18891:
Sure, it's unassigned so feel free to g
mjsax opened a new pull request, #19052:
URL: https://github.com/apache/kafka/pull/19052
The PageView example depends on Connect to pull in Json (de)serializers, but
Connect does not support Java11 any longer.
To allow supporting Java11 for the Kafka Streams examples, this PR removes
[
https://issues.apache.org/jira/browse/KAFKA-18892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
黃竣陽 reassigned KAFKA-18892:
---
Assignee: 黃竣陽
> Add support for ClientQuotaCallback
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-18896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
黃竣陽 reassigned KAFKA-18896:
---
Assignee: 黃竣陽
> Add support for Login
> -
>
> Key: KAFKA-18896
>
cadonna commented on code in PR #19043:
URL: https://github.com/apache/kafka/pull/19043#discussion_r1974015099
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestState.java:
##
@@ -0,0 +1,107 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/KAFKA-18898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931318#comment-17931318
]
黃竣陽 commented on KAFKA-18898:
-
Hello [~davidarthur] ,The {{zk2kraft}} page has been moved to
chia7712 commented on PR #19048:
URL: https://github.com/apache/kafka/pull/19048#issuecomment-2689265249
cherry-pick to 4.0
--
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
chia7712 merged PR #19048:
URL: https://github.com/apache/kafka/pull/19048
--
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
[
https://issues.apache.org/jira/browse/KAFKA-18371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-18371:
---
Fix Version/s: 4.1.0
(was: 4.1)
> TopicBasedRemoteLogMetadataManagerC
chia7712 merged PR #18349:
URL: https://github.com/apache/kafka/pull/18349
--
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
chia7712 commented on PR #19048:
URL: https://github.com/apache/kafka/pull/19048#issuecomment-2689263012
for future reviewers, I have opened
https://issues.apache.org/jira/browse/KAFKA-18885 to add the "behavioral
differences between ZooKeeper and KRaft" - that will include the missing
fea
[
https://issues.apache.org/jira/browse/KAFKA-18860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-18860.
Resolution: Fixed
trunk:
[https://github.com/apache/kafka/commit/e2d9ced098c35068900746af
junrao merged PR #19044:
URL: https://github.com/apache/kafka/pull/19044
--
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.o
[
https://issues.apache.org/jira/browse/KAFKA-18817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lan Ding reassigned KAFKA-18817:
Assignee: Lan Ding (was: Shivsundar R)
> ShareGroupHeartbeat and ShareGroupDescribe API must che
apoorvmittal10 opened a new pull request, #19053:
URL: https://github.com/apache/kafka/pull/19053
There isn't any flaky test for SharePartitionManager in last 7 days,
removing flaky annotation.
https://develocity.apache.org/scans/tests?search.timeZoneId=Europe%2FLondon&tests.containe
[
https://issues.apache.org/jira/browse/KAFKA-18883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang reassigned KAFKA-18883:
-
Assignee: TaiJuWu (was: PoAn Yang)
> Move TransactionLog to transaction-coordinator module
> -
David Arthur created KAFKA-18898:
Summary: 4.0 Upgrade docs rendering below other versions
Key: KAFKA-18898
URL: https://issues.apache.org/jira/browse/KAFKA-18898
Project: Kafka
Issue Type: B
apoorvmittal10 commented on code in PR #19045:
URL: https://github.com/apache/kafka/pull/19045#discussion_r1974546851
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -1326,6 +1355,42 @@ int leaderEpoch() {
return leaderEpoch;
}
+// Visible
apoorvmittal10 commented on code in PR #19045:
URL: https://github.com/apache/kafka/pull/19045#discussion_r1974552557
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -1291,13 +1303,30 @@ public boolean maybeAcquireFetchLock() {
if (stateNotActive())
[
https://issues.apache.org/jira/browse/KAFKA-18897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingdao Yang reassigned KAFKA-18897:
Assignee: Mingdao Yang
> Add support for SslEngineFactory
> -
[
https://issues.apache.org/jira/browse/KAFKA-18894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931297#comment-17931297
]
Jhen-Yung Hsu commented on KAFKA-18894:
---
I'm working on this, thanks :)
> Add sup
[
https://issues.apache.org/jira/browse/KAFKA-18890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jhen-Yung Hsu reassigned KAFKA-18890:
-
Assignee: Jhen-Yung Hsu
> Add support for CreateTopicPolicy and AlterConfigPolicy
> ---
[
https://issues.apache.org/jira/browse/KAFKA-18895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingdao Yang reassigned KAFKA-18895:
Assignee: Mingdao Yang
> Add support for AuthenticateCallbackHandler
> --
[
https://issues.apache.org/jira/browse/KAFKA-18890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931296#comment-17931296
]
Jhen-Yung Hsu commented on KAFKA-18890:
---
I'm working on this, thanks :)
> Add sup
[
https://issues.apache.org/jira/browse/KAFKA-18898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931317#comment-17931317
]
Chia-Ping Tsai commented on KAFKA-18898:
[~davidarthur] Are you testing the 4.0
[
https://issues.apache.org/jira/browse/KAFKA-18898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
黃竣陽 updated KAFKA-18898:
Attachment: image-2025-02-28-06-28-28-356.png
> 4.0 Upgrade docs rendering below other versions
>
[
https://issues.apache.org/jira/browse/KAFKA-18898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
黃竣陽 updated KAFKA-18898:
Attachment: image-2025-02-28-06-29-11-204.png
> 4.0 Upgrade docs rendering below other versions
>
Mickael Maison created KAFKA-18890:
--
Summary: Add support for CreateTopicPolicy and AlterConfigPolicy
Key: KAFKA-18890
URL: https://issues.apache.org/jira/browse/KAFKA-18890
Project: Kafka
I
kevin-wu24 commented on PR #18987:
URL: https://github.com/apache/kafka/pull/18987#issuecomment-2688961782
https://github.com/apache/kafka/pull/18987#discussion_r1971722138 contains
the most recent observation on what is going on when we're checking the
`MajorityReachedHighWatermark` invari
[
https://issues.apache.org/jira/browse/KAFKA-18891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931278#comment-17931278
]
TaiJuWu commented on KAFKA-18891:
-
Hi[~mimaison] , may I take this over if you are not w
gongxuanzhang commented on code in PR #19036:
URL: https://github.com/apache/kafka/pull/19036#discussion_r1974595611
##
clients/src/main/java/org/apache/kafka/clients/admin/AbortTransactionOptions.java:
##
@@ -16,9 +16,7 @@
*/
package org.apache.kafka.clients.admin;
-import
cadonna commented on PR #19043:
URL: https://github.com/apache/kafka/pull/19043#issuecomment-2687387498
Call for review: @aliehsaeedii
--
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
Chia-Ping Tsai created KAFKA-18881:
--
Summary: Document the ConsumerRecord as non-thread safe
Key: KAFKA-18881
URL: https://issues.apache.org/jira/browse/KAFKA-18881
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-18471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-18471.
Resolution: Duplicate
duplicate to KAFKA-18470
> Race conditions when accessing RecordHe
[
https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931070#comment-17931070
]
Luke Chen edited comment on KAFKA-18871 at 2/27/25 9:34 AM:
sjhajharia commented on PR #19008:
URL: https://github.com/apache/kafka/pull/19008#issuecomment-2687360738
hey @chia7712
Can you please take a look at this PR too. TIA
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
[
https://issues.apache.org/jira/browse/KAFKA-18880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-18880:
--
Assignee: xuanzhang gong (was: Lan Ding)
> Remove kafka.cluster.Broker and BrokerEnd
[
https://issues.apache.org/jira/browse/KAFKA-18880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931066#comment-17931066
]
xuanzhang gong commented on KAFKA-18880:
Hello, I have sent PR to solve this iss
[
https://issues.apache.org/jira/browse/KAFKA-18880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931067#comment-17931067
]
Chia-Ping Tsai commented on KAFKA-18880:
[~isding_l] sorry that it seems [~gongx
[
https://issues.apache.org/jira/browse/KAFKA-18880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lan Ding reassigned KAFKA-18880:
Assignee: Lan Ding
> Remove kafka.cluster.Broker and BrokerEndPointNotAvailableException
> --
gongxuanzhang opened a new pull request, #19047:
URL: https://github.com/apache/kafka/pull/19047
Remove kafka.cluster.Broker and BrokerEndPointNotAvailableException
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
AndrewJSchofield commented on code in PR #18963:
URL: https://github.com/apache/kafka/pull/18963#discussion_r1973200080
##
tools/src/main/java/org/apache/kafka/tools/ShareConsumerPerformance.java:
##
@@ -79,7 +79,8 @@ public static void main(String[] args) {
sha
[
https://issues.apache.org/jira/browse/KAFKA-18881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Logan Zhu reassigned KAFKA-18881:
-
Assignee: Logan Zhu (was: Chia-Ping Tsai)
> Document the ConsumerRecord as non-thread safe
> -
[
https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931070#comment-17931070
]
Luke Chen commented on KAFKA-18871:
---
[~durban] , thanks for reporting. Could you share
Chia-Ping Tsai created KAFKA-18882:
--
Summary: Move BaseKey, TxnKey, and UnknownKey to
transaction-coordinator module
Key: KAFKA-18882
URL: https://issues.apache.org/jira/browse/KAFKA-18882
Project: K
PoAn Yang created KAFKA-18884:
-
Summary: Move TransactionMetadata to transaction-coordinator module
Key: KAFKA-18884
URL: https://issues.apache.org/jira/browse/KAFKA-18884
Project: Kafka
Issue Ty
chia7712 commented on code in PR #19019:
URL: https://github.com/apache/kafka/pull/19019#discussion_r1973272253
##
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala:
##
@@ -82,16 +83,6 @@ object DynamicBrokerConfig {
private[server] val DynamicSecurityConfigs =
SslC
PoAn Yang created KAFKA-18883:
-
Summary: Move TransactionLog to transaction-coordinator module
Key: KAFKA-18883
URL: https://issues.apache.org/jira/browse/KAFKA-18883
Project: Kafka
Issue Type: S
[
https://issues.apache.org/jira/browse/KAFKA-16708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931084#comment-17931084
]
krish7919 commented on KAFKA-16708:
---
I have the same use case. I run kafka as a depend
[
https://issues.apache.org/jira/browse/KAFKA-18820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931102#comment-17931102
]
Chia-Ping Tsai commented on KAFKA-18820:
4.0 does not use netty
> CVE-2025-2497
[
https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931192#comment-17931192
]
Paolo Patierno commented on KAFKA-18871:
> The logs cover a large timespan, but
[
https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Urban updated KAFKA-18871:
-
Attachment: cluster-operator.log.zip
> KRaft migration rollback causes downtime
> --
clarkwtc commented on code in PR #19046:
URL: https://github.com/apache/kafka/pull/19046#discussion_r1973760130
##
core/src/test/java/kafka/test/api/ProducerRebootstrapTest.java:
##
@@ -0,0 +1,121 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
clarkwtc commented on code in PR #19046:
URL: https://github.com/apache/kafka/pull/19046#discussion_r1973768673
##
core/src/test/java/kafka/test/api/ProducerRebootstrapTest.java:
##
@@ -0,0 +1,121 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
clarkwtc commented on code in PR #19046:
URL: https://github.com/apache/kafka/pull/19046#discussion_r1973769247
##
core/src/test/java/kafka/test/api/ProducerRebootstrapTest.java:
##
@@ -0,0 +1,121 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
1 - 100 of 166 matches
Mail list logo
