FrankYang0529 commented on code in PR #18802:
URL: https://github.com/apache/kafka/pull/18802#discussion_r1973058360
##
metadata/src/main/java/org/apache/kafka/metadata/publisher/AclPublisher.java:
##
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
chia7712 commented on code in PR #19038:
URL: https://github.com/apache/kafka/pull/19038#discussion_r1973070151
##
server/src/main/java/org/apache/kafka/server/config/ServerConfigs.java:
##
@@ -52,7 +52,8 @@ public class ServerConfigs {
public static final String BACKGROUND
FrankYang0529 commented on code in PR #18802:
URL: https://github.com/apache/kafka/pull/18802#discussion_r1973100776
##
metadata/src/main/java/org/apache/kafka/metadata/publisher/AclPublisher.java:
##
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
chia7712 commented on PR #19016:
URL: https://github.com/apache/kafka/pull/19016#issuecomment-2687190842
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 comment.
chia7712 merged PR #19016:
URL: https://github.com/apache/kafka/pull/19016
--
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-18849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-18849.
Resolution: Fixed
trunk:
[https://github.com/apache/kafka/commit/269e2d898b76b5c9c58232c3
chia7712 commented on code in PR #18802:
URL: https://github.com/apache/kafka/pull/18802#discussion_r1973092684
##
metadata/src/main/java/org/apache/kafka/metadata/publisher/AclPublisher.java:
##
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under on
[
https://issues.apache.org/jira/browse/KAFKA-18870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Szu-Yung Wang reassigned KAFKA-18870:
-
Assignee: Szu-Yung Wang (was: TaiJuWu)
> implement describeDelegationToken for control
m1a2st commented on code in PR #19046:
URL: https://github.com/apache/kafka/pull/19046#discussion_r1973122449
##
core/src/test/java/kafka/test/api/ProducerRebootstrapTest.java:
##
@@ -0,0 +1,121 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * co
chia7712 merged PR #19009:
URL: https://github.com/apache/kafka/pull/19009
--
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 code in PR #18801:
URL: https://github.com/apache/kafka/pull/18801#discussion_r1973109296
##
core/src/main/scala/kafka/server/metadata/KRaftMetadataCache.scala:
##
@@ -345,68 +352,75 @@ class KRaftMetadataCache(
Option(_currentImage.cluster.broker(bro
Chia-Ping Tsai created KAFKA-18880:
--
Summary: Remove kafka.cluster.Broker and
BrokerEndPointNotAvailableException
Key: KAFKA-18880
URL: https://issues.apache.org/jira/browse/KAFKA-18880
Project: Kafk
Chia-Ping Tsai created KAFKA-18886:
--
Summary: add behavior change of CreateTopicPolicy and
AlterConfigPolicy to zk2kraft
Key: KAFKA-18886
URL: https://issues.apache.org/jira/browse/KAFKA-18886
Projec
[
https://issues.apache.org/jira/browse/KAFKA-18882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931118#comment-17931118
]
Dmitry Werner commented on KAFKA-18882:
---
[~chia7712] Hello, can I work on this tas
[
https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Urban updated KAFKA-18871:
-
Attachment: kraft-rollback-bug.zip
> KRaft migration rollback causes downtime
>
frankvicky opened a new pull request, #19048:
URL: https://github.com/apache/kafka/pull/19048
JIRA: KAFKA-18860
The content of Missing Features has been documented in zk2kraft.html. Hence,
we could remove it
Reviewers:
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/KAFKA-18860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931107#comment-17931107
]
Chia-Ping Tsai commented on KAFKA-18860:
in the zk2kraft, we have write down the
[
https://issues.apache.org/jira/browse/KAFKA-18860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-18860:
---
Fix Version/s: 4.0.0
> Clarify the KRaft missing feature
> -
Chia-Ping Tsai created KAFKA-18885:
--
Summary: document the behavioral differences between ZooKeeper and
KRaft
Key: KAFKA-18885
URL: https://issues.apache.org/jira/browse/KAFKA-18885
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-18860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-18860:
---
Parent: KAFKA-18885
Issue Type: Sub-task (was: Bug)
> Clarify the KRaft missing fea
[
https://issues.apache.org/jira/browse/KAFKA-18886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931109#comment-17931109
]
Chia-Ping Tsai commented on KAFKA-18886:
Additionally, we should update the docu
[
https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931121#comment-17931121
]
Daniel Urban commented on KAFKA-18871:
--
[~showuon] Thank you for checking this!
I
AndrewJSchofield commented on code in PR #19045:
URL: https://github.com/apache/kafka/pull/19045#discussion_r1973396006
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -1265,19 +1289,7 @@ boolean canAcquireRecords() {
if (nextFetchOffset() != endOffs
AndrewJSchofield commented on code in PR #18976:
URL: https://github.com/apache/kafka/pull/18976#discussion_r1973409686
##
clients/src/main/java/org/apache/kafka/clients/admin/DeleteShareGroupOffsetsResult.java:
##
@@ -0,0 +1,97 @@
+/*
+ * Licensed to the Apache Software Foundat
chia7712 commented on code in PR #18662:
URL: https://github.com/apache/kafka/pull/18662#discussion_r1973443282
##
test-common/test-common-runtime/src/test/java/org/apache/kafka/common/test/junit/ClusterTestBeforeEachTest.java:
##
@@ -0,0 +1,59 @@
+/*
+ * Licensed to the Apache
Yunyung commented on code in PR #18918:
URL: https://github.com/apache/kafka/pull/18918#discussion_r1973445909
##
build.gradle:
##
@@ -2485,7 +2485,9 @@ project(':tools') {
from (configurations.runtimeClasspath) {
exclude('kafka-clients*')
}
-from (configura
[
https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931133#comment-17931133
]
Daniel Urban commented on KAFKA-18871:
--
[~ppatierno] Thanks for checking the logs.
Alieh Saeedi created KAFKA-18887:
Summary: Implement Admin API extensions beyond list/describe group
(delete group, offset-related APIs)
Key: KAFKA-18887
URL: https://issues.apache.org/jira/browse/KAFKA-18887
[
https://issues.apache.org/jira/browse/KAFKA-18887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi updated KAFKA-18887:
-
Description:
* add methods for describing and manipulating offsets as described in KIP-1071
*
[
https://issues.apache.org/jira/browse/KAFKA-18887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi reassigned KAFKA-18887:
Assignee: Alieh Saeedi
> Implement Admin API extensions beyond list/describe group (delet
aliehsaeedii opened a new pull request, #19049:
URL: https://github.com/apache/kafka/pull/19049
https://issues.apache.org/jira/browse/KAFKA-18887
--
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
m1a2st commented on code in PR #19034:
URL: https://github.com/apache/kafka/pull/19034#discussion_r1973418908
##
tests/kafkatest/services/kafka/quorum.py:
##
@@ -14,14 +14,10 @@
# limitations under the License.
# the types of metadata quorums we support
-zk = 'ZK' # ZooKeepe
Mickael Maison created KAFKA-1:
--
Summary: Add support for Authorizer
Key: KAFKA-1
URL: https://issues.apache.org/jira/browse/KAFKA-1
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931126#comment-17931126
]
Paolo Patierno commented on KAFKA-18871:
I had a look at the operator log and it
Apoorv Mittal created KAFKA-18889:
-
Summary: Make records in ShareFetchResponse non-nullable
Key: KAFKA-18889
URL: https://issues.apache.org/jira/browse/KAFKA-18889
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-18886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Logan Zhu reassigned KAFKA-18886:
-
Assignee: Logan Zhu (was: Chia-Ping Tsai)
> add behavior change of CreateTopicPolicy and Alter
AndrewJSchofield commented on code in PR #19026:
URL: https://github.com/apache/kafka/pull/19026#discussion_r1973313677
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -463,6 +472,19 @@ GroupMetadataManager build() {
*
frankvicky commented on PR #19048:
URL: https://github.com/apache/kafka/pull/19048#issuecomment-2687668866
It was between "Deploying Considerations" and "ZooKeeper to KRaft
Migration". Now it's gone.
Preview:
> Move BaseKey, TxnKey, and UnknownKe
[
https://issues.apache.org/jira/browse/KAFKA-18882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931130#comment-17931130
]
Chia-Ping Tsai commented on KAFKA-18882:
[~javakillah] sorry that we are working
apoorvmittal10 commented on code in PR #19045:
URL: https://github.com/apache/kafka/pull/19045#discussion_r1973509905
##
server/src/main/java/org/apache/kafka/server/share/metrics/SharePartitionMetrics.java:
##
@@ -0,0 +1,166 @@
+/*
+ * Licensed to the Apache Software Foundation
Wadimz commented on PR #18349:
URL: https://github.com/apache/kafka/pull/18349#issuecomment-2687852370
thanks for reminder! I've updated the branch from trunk. @chia7712 could you
please check when have time? thanks!
--
This is an automated message from the Apache Git Service.
To respond
apoorvmittal10 commented on code in PR #19045:
URL: https://github.com/apache/kafka/pull/19045#discussion_r1973510264
##
server/src/main/java/org/apache/kafka/server/share/metrics/SharePartitionMetrics.java:
##
@@ -0,0 +1,166 @@
+/*
+ * Licensed to the Apache Software Foundation
smjn commented on PR #19026:
URL: https://github.com/apache/kafka/pull/19026#issuecomment-2687877409
@AndrewJSchofield
Thanks for the review, incorporated changes
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
ijuma commented on code in PR #19031:
URL: https://github.com/apache/kafka/pull/19031#discussion_r1973623540
##
build.gradle:
##
@@ -54,7 +54,7 @@ ext {
buildVersionFileName = "kafka-version.properties"
defaultMaxHeapSize = "2g"
- defaultJvmArgs = ["-Xss4m", "-XX:+UsePa
[
https://issues.apache.org/jira/browse/KAFKA-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931172#comment-17931172
]
Daniel Urban commented on KAFKA-18871:
--
[~ppatierno] I agree that this issue does n
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
1 - 100 of 166 matches
Mail list logo
