Parkerhiphop commented on PR #19213:
URL: https://github.com/apache/kafka/pull/19213#issuecomment-2728550547
Local testing screenshot:
For valid and invalid string
![CleanShot 2025-03-1
[
https://issues.apache.org/jira/browse/KAFKA-18760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936126#comment-17936126
]
PoAn Yang commented on KAFKA-18760:
---
KIP:
[https://cwiki.apache.org/confluence/pages/
m1a2st commented on PR #19214:
URL: https://github.com/apache/kafka/pull/19214#issuecomment-2729022427
Hello @frankvicky, I don’t think we need to update the Javadoc. We are still
finding "the file position of the message batch whose last offset is greater
than or equal to the target offset
David Arthur created KAFKA-19000:
Summary: Flaky test report should use absolute time for links
Key: KAFKA-19000
URL: https://issues.apache.org/jira/browse/KAFKA-19000
Project: Kafka
Issue Ty
mumrah commented on PR #19179:
URL: https://github.com/apache/kafka/pull/19179#issuecomment-2729690621
We should probably make the links in the report use absolute time instead of
the "last 7 days" filter. Filed
https://issues.apache.org/jira/browse/KAFKA-19000 to fix this
--
This is an
[
https://issues.apache.org/jira/browse/KAFKA-18999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936206#comment-17936206
]
Ismael Juma commented on KAFKA-18999:
-
That makes sense.
> Remove BrokerMetadata
>
chia7712 commented on code in PR #19213:
URL: https://github.com/apache/kafka/pull/19213#discussion_r1998755108
##
tools/src/main/java/org/apache/kafka/tools/ClientMetricsCommand.java:
##
@@ -241,7 +241,7 @@ public ClientMetricsCommandOptions(String[] args) {
interv
mumrah commented on code in PR #19214:
URL: https://github.com/apache/kafka/pull/19214#discussion_r1998877164
##
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java:
##
@@ -464,6 +481,12 @@ public static class LogOffsetPosition {
public final int posit
[
https://issues.apache.org/jira/browse/KAFKA-14579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936261#comment-17936261
]
TaiJuWu commented on KAFKA-14579:
-
Hi [~adupriez] , are you still working on this?
If no
[
https://issues.apache.org/jira/browse/KAFKA-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-18808.
Resolution: Fixed
> add test to ensure the name= is not equal to default quota
> -
chia7712 commented on code in PR #18463:
URL: https://github.com/apache/kafka/pull/18463#discussion_r1998752540
##
core/src/test/java/kafka/server/BootstrapControllersIntegrationTest.java:
##
@@ -342,4 +343,22 @@ private void testAcls(ClusterInstance clusterInstance,
boolean us
sebastienviale commented on PR #18739:
URL: https://github.com/apache/kafka/pull/18739#issuecomment-2729806425
As @loicgreffier said, it is mentioned in the KIP that the raw record value:
"If available, contains the value of the input message that triggered the
sub-topology, null if trigger
Lucas Brutschy created KAFKA-19001:
--
Summary: Use streams group-level configurations in heartbeat
Key: KAFKA-19001
URL: https://issues.apache.org/jira/browse/KAFKA-19001
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-19001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy reassigned KAFKA-19001:
--
Assignee: Lucas Brutschy
> Use streams group-level configurations in heartbeat
>
cmccabe commented on code in PR #18949:
URL: https://github.com/apache/kafka/pull/18949#discussion_r1999661209
##
core/src/main/scala/kafka/server/BrokerServer.scala:
##
@@ -194,6 +194,7 @@ class BrokerServer(
val clientMetricsReceiverPlugin = new ClientMetricsReceiverP
cmccabe commented on code in PR #18949:
URL: https://github.com/apache/kafka/pull/18949#discussion_r1999661209
##
core/src/main/scala/kafka/server/BrokerServer.scala:
##
@@ -194,6 +194,7 @@ class BrokerServer(
val clientMetricsReceiverPlugin = new ClientMetricsReceiverP
cmccabe merged PR #19165:
URL: https://github.com/apache/kafka/pull/19165
--
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.
cmccabe commented on code in PR #18949:
URL: https://github.com/apache/kafka/pull/18949#discussion_r1999664781
##
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala:
##
@@ -192,6 +197,37 @@ object DynamicBrokerConfig {
}
props
}
+
+ private[server] def read
cmccabe commented on PR #19165:
URL: https://github.com/apache/kafka/pull/19165#issuecomment-2730918434
Thanks @ahuang98 . Committed.
@mannoopj , you may want to configure your email better. It's showing up as
`139923522+manno...@users.noreply.github.com` which I don't think is what y
CalvinConfluent commented on PR #19180:
URL: https://github.com/apache/kafka/pull/19180#issuecomment-2730933066
@cmccabe Updated the name from `electionWithElr` to `electionFromElr`
The KIP has been updated with this metric. I have emailed the change in the
KIP-966 discussion thread and n
kevin-wu24 commented on code in PR #18949:
URL: https://github.com/apache/kafka/pull/18949#discussion_r1999696908
##
core/src/main/scala/kafka/server/BrokerServer.scala:
##
@@ -194,6 +194,7 @@ class BrokerServer(
val clientMetricsReceiverPlugin = new ClientMetricsReceiv
bachmanity1 commented on PR #18828:
URL: https://github.com/apache/kafka/pull/18828#issuecomment-2731387765
Hi @cmccabe @chia7712 @ijuma, could you take a look, please?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
dengziming commented on PR #19110:
URL: https://github.com/apache/kafka/pull/19110#issuecomment-2731431118
@chia7712 Thank your for reviewing this, I changed the naming methodology,
the build is green, PATL.
--
This is an automated message from the Apache Git Service.
To respond to the me
chad-wheeler-sp commented on PR #8103:
URL: https://github.com/apache/kafka/pull/8103#issuecomment-2730982287
@senthilm-ms senthilm-ms] Why did this feature die?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
kirktrue commented on code in PR #19217:
URL: https://github.com/apache/kafka/pull/19217#discussion_r1999895425
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/DescribeAuthorizedOperationsTest.java:
##
@@ -154,7 +147,7 @@ public void
testConsum
chia7712 merged PR #19202:
URL: https://github.com/apache/kafka/pull/19202
--
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-18969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-18969.
Fix Version/s: 4.1.0
Resolution: Fixed
> Rewrite ShareConsumerTest#setup by beforeE
chia7712 commented on code in PR #19207:
URL: https://github.com/apache/kafka/pull/19207#discussion_r2000323926
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -875,7 +872,7 @@ public boolean cleanupExpiredOffsets(String gr
mumrah commented on PR #19031:
URL: https://github.com/apache/kafka/pull/19031#issuecomment-2730836657
@chia7712 thanks for investigating. The metric creation inside a loop sounds
like the likely culprit.
--
This is an automated message from the Apache Git Service.
To respond to the mess
jolshan commented on code in PR #19193:
URL: https://github.com/apache/kafka/pull/19193#discussion_r1999826677
##
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorTest.scala:
##
@@ -1070,26 +1146,47 @@ class TransactionCoordinatorTest {
})
Ritika Reddy created KAFKA-19003:
Summary: Add force-terminate command to kafka-transactions CLI
Key: KAFKA-19003
URL: https://issues.apache.org/jira/browse/KAFKA-19003
Project: Kafka
Issue
kevin-wu24 commented on PR #18304:
URL: https://github.com/apache/kafka/pull/18304#issuecomment-2731172907
> > Moved DefaultExternalKRaftMetrics to /core/src/main/scala/kafka/raft to
avoid circular dependency and avoid BrokerServerMetrics and
ControllerMetadataMetrics needing to implement a
github-actions[bot] commented on PR #19085:
URL: https://github.com/apache/kafka/pull/19085#issuecomment-2731500245
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] closed pull request #17425: KAFKA-17727: swallow exceptions
on segment flush
URL: https://github.com/apache/kafka/pull/17425
--
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 s
github-actions[bot] closed pull request #17810: MINOR: Documentation
improvements for dynamic quorums
URL: https://github.com/apache/kafka/pull/17810
--
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
github-actions[bot] commented on PR #17950:
URL: https://github.com/apache/kafka/pull/17950#issuecomment-2731529602
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 P
github-actions[bot] commented on PR #17425:
URL: https://github.com/apache/kafka/pull/17425#issuecomment-2731529431
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
kirktrue commented on code in PR #19214:
URL: https://github.com/apache/kafka/pull/19214#discussion_r103645
##
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java:
##
@@ -298,11 +298,28 @@ public int writeTo(TransferableChannel destChannel, int
offset, int
cmccabe commented on code in PR #18949:
URL: https://github.com/apache/kafka/pull/18949#discussion_r1999661209
##
core/src/main/scala/kafka/server/BrokerServer.scala:
##
@@ -194,6 +194,7 @@ class BrokerServer(
val clientMetricsReceiverPlugin = new ClientMetricsReceiverP
[
https://issues.apache.org/jira/browse/KAFKA-19002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-19002:
--
Component/s: clients
> Rewrite ListOffsetsIntegrationTest and move it to clients-integration-test
> --
[
https://issues.apache.org/jira/browse/KAFKA-18986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936104#comment-17936104
]
Lucas Brutschy commented on KAFKA-18986:
We first need KIP-1101 implemented befo
leaf-soba commented on code in PR #18926:
URL: https://github.com/apache/kafka/pull/18926#discussion_r1998286042
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java:
##
@@ -920,10 +917,10 @@ public void
testInitializeAsUnattachedAndBecomeLeader(boolean withKip8
github-actions[bot] commented on PR #19167:
URL: https://github.com/apache/kafka/pull/19167#issuecomment-2727943789
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
m1a2st commented on code in PR #19213:
URL: https://github.com/apache/kafka/pull/19213#discussion_r1998620696
##
tools/src/main/java/org/apache/kafka/tools/ClientMetricsCommand.java:
##
@@ -241,7 +241,7 @@ public ClientMetricsCommandOptions(String[] args) {
interval
OmniaGM commented on PR #15968:
URL: https://github.com/apache/kafka/pull/15968#issuecomment-2728359297
> @OmniaGM any updates here? Thanks for your patience and work so far!
Hi, Sorry for this very late reply. I have been busy with too many things
lately and haven't had time to look
lucasbru commented on code in PR #19114:
URL: https://github.com/apache/kafka/pull/19114#discussion_r1998207274
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -3338,9 +3342,9 @@ private boolean hasMemberSubscriptionChanged(
lucasbru commented on PR #19114:
URL: https://github.com/apache/kafka/pull/19114#issuecomment-2728632732
@bbejeck Thanks for the comments! Ready for re-review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
loicgreffier commented on PR #18739:
URL: https://github.com/apache/kafka/pull/18739#issuecomment-2729270055
@cadonna KIP-1034 suggests that the input record should be the one that
triggers the sub-topology:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1034%3A+Dead+letter+queue+in+
leaf-soba commented on code in PR #18926:
URL: https://github.com/apache/kafka/pull/18926#discussion_r1998298448
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java:
##
@@ -4030,24 +4027,17 @@ public void testMetrics(boolean withKip853Rpc) throws
Exception {
wernerdv commented on PR #19216:
URL: https://github.com/apache/kafka/pull/19216#issuecomment-2728401472
@mimaison @chia7712 Hello, please take a look.
--
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 g
edoardocomar commented on PR #19206:
URL: https://github.com/apache/kafka/pull/19206#issuecomment-2729369615
for information only - related mini PR in a different repo
https://github.com/prometheus/client_java/pull/1307
--
This is an automated message from the Apache Git Service.
To respo
[
https://issues.apache.org/jira/browse/KAFKA-7952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936180#comment-17936180
]
Lorcan commented on KAFKA-7952:
---
Hi [~mjsax] I have created a PR below with an approach tha
[
https://issues.apache.org/jira/browse/KAFKA-18999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936182#comment-17936182
]
Chia-Ping Tsai commented on KAFKA-18999:
[~ijuma] you are right that using `entr
[
https://issues.apache.org/jira/browse/KAFKA-15370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936199#comment-17936199
]
Stanislav Kozlovski commented on KAFKA-15370:
-
What is the target Fix versio
chia7712 merged PR #19071:
URL: https://github.com/apache/kafka/pull/19071
--
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 #19217:
URL: https://github.com/apache/kafka/pull/19217#issuecomment-2730214171
@FrankYang0529 please fix the conflicts and move the
RackAwareAutoTopicCreationTest
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
Chia-Ping Tsai created KAFKA-19002:
--
Summary: Rewrite ListOffsetsIntegrationTest and move it to
clients-integration-test
Key: KAFKA-19002
URL: https://issues.apache.org/jira/browse/KAFKA-19002
Projec
[
https://issues.apache.org/jira/browse/KAFKA-19002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936262#comment-17936262
]
Chia-Ping Tsai commented on KAFKA-19002:
[~javakillah] sorry that [~taijuwu] is
[
https://issues.apache.org/jira/browse/KAFKA-19002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TaiJuWu reassigned KAFKA-19002:
---
Assignee: TaiJuWu (was: Chia-Ping Tsai)
> Rewrite ListOffsetsIntegrationTest and move it to client
fvaleri commented on code in PR #19198:
URL: https://github.com/apache/kafka/pull/19198#discussion_r1999330309
##
docs/upgrade.html:
##
@@ -72,10 +72,8 @@ Upgrading
Servers to 4.0.0 from
brokers will be running the latest version and you can verify that the
cluster's
[
https://issues.apache.org/jira/browse/KAFKA-19002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936264#comment-17936264
]
Dmitry Werner commented on KAFKA-19002:
---
no problem :)
> Rewrite ListOffsetsInteg
chia7712 commented on PR #18304:
URL: https://github.com/apache/kafka/pull/18304#issuecomment-2730334817
> Moved DefaultExternalKRaftMetrics to /core/src/main/scala/kafka/raft to
avoid circular dependency and avoid BrokerServerMetrics and
ControllerMetadataMetrics needing to implement anoth
TaiJuWu opened a new pull request, #19220:
URL: https://github.com/apache/kafka/pull/19220
JIRA: https://issues.apache.org/jira/browse/KAFKA-18679
The following metrics are being exposed as floating point doubles instead of
ints/longs:
- log-end-offset
- log-end-epoch
- n
chia7712 merged PR #18463:
URL: https://github.com/apache/kafka/pull/18463
--
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-17171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-17171.
Fix Version/s: 4.1.0
Resolution: Fixed
> Add test cases for `STATIC_BROKER_CONFIG`i
[
https://issues.apache.org/jira/browse/KAFKA-18992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-18992:
---
Component/s: controller
kraft
> kafka-features.sh w
[
https://issues.apache.org/jira/browse/KAFKA-18992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936228#comment-17936228
]
José Armando García Sancio edited comment on KAFKA-18992 at 3/17/25 4:03 PM:
-
chia7712 merged PR #18801:
URL: https://github.com/apache/kafka/pull/18801
--
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-18992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936231#comment-17936231
]
TengYao Chi commented on KAFKA-18992:
-
Hi [~jsancio]
Thanks for the explanation :)
[
https://issues.apache.org/jira/browse/KAFKA-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-17565.
Resolution: Fixed
> Move MetadataCache interface to metadata module
>
m1a2st commented on code in PR #19214:
URL: https://github.com/apache/kafka/pull/19214#discussion_r1999093157
##
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java:
##
@@ -298,11 +298,28 @@ public int writeTo(TransferableChannel destChannel, int
offset, int l
chia7712 commented on code in PR #19213:
URL: https://github.com/apache/kafka/pull/19213#discussion_r1999098658
##
tools/src/test/java/org/apache/kafka/tools/ClientMetricsCommandTest.java:
##
@@ -156,6 +166,27 @@ public void testAlterGenerateName() {
assertTrue(captured
m1a2st commented on PR #19214:
URL: https://github.com/apache/kafka/pull/19214#issuecomment-2730090896
> Also, how about the case where a target offset lies between batches (which
I think is possible due to compaction
In the previous logic, it would point to the next batch. For exampl
CalvinConfluent commented on code in PR #19194:
URL: https://github.com/apache/kafka/pull/19194#discussion_r1999125992
##
tests/kafkatest/services/kafka/kafka.py:
##
@@ -330,7 +327,7 @@ def __init__(self, context, num_nodes, zk,
security_protocol=SecurityConfig.PLAI
mumrah commented on PR #19179:
URL: https://github.com/apache/kafka/pull/19179#issuecomment-2729676268
The report was generated on March 10th, if you look at the 7 days prior to
that, you'll see a lot more failures
https://github.com/user-attachments/assets/91569321-47a9-4536-9d60-95
TaiJuWu opened a new pull request, #19222:
URL: https://github.com/apache/kafka/pull/19222
Delete this text and replace it with a detailed description of your change.
The
PR title and body will become the squashed commit message.
If you would like to tag individuals, add some comm
junrao commented on code in PR #19214:
URL: https://github.com/apache/kafka/pull/19214#discussion_r1999287436
##
clients/src/test/java/org/apache/kafka/common/record/FileRecordsTest.java:
##
@@ -518,6 +523,176 @@ public void testBytesLengthOfWriteTo() throws IOException
{
[
https://issues.apache.org/jira/browse/KAFKA-19000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
黃竣陽 reassigned KAFKA-19000:
---
Assignee: 黃竣陽
> Flaky test report should use absolute time for links
>
lucasbru opened a new pull request, #19219:
URL: https://github.com/apache/kafka/pull/19219
Implements the use of session timeout, standby tasks and heartbeat interval
configurations in the streams group heartbeat.
Piggy-backed is another test that streams groups react to changes
[
https://issues.apache.org/jira/browse/KAFKA-18992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-18992:
---
Affects Version/s: 4.0.0
> kafka-features.sh wronly output `upgraded
[
https://issues.apache.org/jira/browse/KAFKA-18992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-18992:
---
Fix Version/s: 4.1.0
> kafka-features.sh wronly output `upgraded kra
[
https://issues.apache.org/jira/browse/KAFKA-18992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936228#comment-17936228
]
José Armando García Sancio commented on KAFKA-18992:
[~frankvicky] T
[
https://issues.apache.org/jira/browse/KAFKA-18992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio reassigned KAFKA-18992:
--
Assignee: José Armando García Sancio (was: TengYao Chi)
> ka
Parkerhiphop commented on code in PR #19213:
URL: https://github.com/apache/kafka/pull/19213#discussion_r1998990551
##
tools/src/main/java/org/apache/kafka/tools/ClientMetricsCommand.java:
##
@@ -241,7 +241,7 @@ public ClientMetricsCommandOptions(String[] args) {
in
srdo opened a new pull request, #19221:
URL: https://github.com/apache/kafka/pull/19221
Backport for 3.9 for https://github.com/apache/kafka/pull/16522
The reason to do this is that this is necessary in order for 3.9 to support
Java 24.
Please see https://lists.apache.org/threa
chia7712 commented on code in PR #19174:
URL: https://github.com/apache/kafka/pull/19174#discussion_r1999272304
##
server/src/main/java/org/apache/kafka/server/config/BrokerReconfigurable.java:
##
@@ -0,0 +1,25 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under on
github-actions[bot] commented on PR #17571:
URL: https://github.com/apache/kafka/pull/17571#issuecomment-2728031146
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
chia7712 commented on code in PR #19214:
URL: https://github.com/apache/kafka/pull/19214#discussion_r1999448126
##
clients/src/test/java/org/apache/kafka/common/record/FileRecordsTest.java:
##
@@ -518,6 +523,176 @@ public void testBytesLengthOfWriteTo() throws IOException
{
[
https://issues.apache.org/jira/browse/KAFKA-19002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936263#comment-17936263
]
TaiJuWu commented on KAFKA-19002:
-
Sorry [~javakillah] , I would like to pick it up afte
chia7712 commented on code in PR #19214:
URL: https://github.com/apache/kafka/pull/19214#discussion_r1999450816
##
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java:
##
@@ -298,11 +298,28 @@ public int writeTo(TransferableChannel destChannel, int
offset, int
[
https://issues.apache.org/jira/browse/KAFKA-18818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936271#comment-17936271
]
Ritvik Gupta commented on KAFKA-18818:
--
Hi,
Just have a few follow up queries base
chia7712 merged PR #18966:
URL: https://github.com/apache/kafka/pull/18966
--
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
lucasbru commented on code in PR #19189:
URL: https://github.com/apache/kafka/pull/19189#discussion_r1991580254
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -2246,25 +2246,27 @@ private StreamsTopology maybeUpdateTopology
93 matches
Mail list logo
