frankvicky commented on PR #19400:
URL: https://github.com/apache/kafka/pull/19400#issuecomment-2791810133
Hi @ableegoldman
Please take a look when you have a free moment.
I have some questions since I'm not familiar with the stream module.
Please bear with me if the code looks like
frankvicky commented on code in PR #19400:
URL: https://github.com/apache/kafka/pull/19400#discussion_r2036675899
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -1205,45 +1200,9 @@ private Optional removeStreamThread(final long
timeoutMs) throws Time
lucasbru commented on code in PR #19425:
URL: https://github.com/apache/kafka/pull/19425#discussion_r2037278831
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java:
##
@@ -140,6 +140,19 @@ public EmbeddedKafkaCluster(fi
lucasbru commented on PR #19425:
URL: https://github.com/apache/kafka/pull/19425#issuecomment-2792673278
Thanks for the comments @FrankYang0529, addressed!
--
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
AndrewJSchofield opened a new pull request, #19435:
URL: https://github.com/apache/kafka/pull/19435
Create a single formatter for use with `kafka-console-consumer.sh` that
formats all record types for share groups on the `__consumer_offsets` topic.
--
This is an automated message from the
Omnia Ibrahim created KAFKA-19125:
-
Summary: Implement Large message reference-based Serializer
Key: KAFKA-19125
URL: https://issues.apache.org/jira/browse/KAFKA-19125
Project: Kafka
Issue Ty
adixitconfluent opened a new pull request, #19437:
URL: https://github.com/apache/kafka/pull/19437
### What
This PR adds the support for remote storage fetch for share groups.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/KAFKA-19126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Adrian C. updated KAFKA-19126:
--
Description:
We have observed during normal operations that messages/batches can be written
to disk w
m1a2st commented on code in PR #19286:
URL: https://github.com/apache/kafka/pull/19286#discussion_r2037585875
##
server/src/test/java/org/apache/kafka/server/MonitorablePluginsIntegrationTest.java:
##
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
[
https://issues.apache.org/jira/browse/KAFKA-19110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang reassigned KAFKA-19110:
-
Assignee: PoAn Yang (was: Bruno Cadonna)
> Add missing unit test for Streams-consumer integrat
cadonna commented on code in PR #19421:
URL: https://github.com/apache/kafka/pull/19421#discussion_r2037577517
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -180,6 +186,25 @@ public class AsyncKafkaConsumer implements
Consum
smjn commented on PR #19432:
URL: https://github.com/apache/kafka/pull/19432#issuecomment-2792255361
@AndrewJSchofield thanks for pointing out, fixed
--
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
apoorvmittal10 commented on code in PR #19378:
URL: https://github.com/apache/kafka/pull/19378#discussion_r2037272992
##
clients/src/main/java/org/apache/kafka/common/requests/AlterShareGroupOffsetsRequest.java:
##
@@ -41,7 +41,7 @@ public static class Builder extends
AbstractR
chia7712 commented on PR #19371:
URL: https://github.com/apache/kafka/pull/19371#issuecomment-2792577675
for example:
```java
this.internalSegmentSize =
getString(TopicConfig.INTERNAL_SEGMENT_BYTES_CONFIG);
...
public long segmentSize() {
i
cadonna commented on code in PR #19421:
URL: https://github.com/apache/kafka/pull/19421#discussion_r2037412696
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SmokeTestDriverIntegrationTest.java:
##
@@ -120,6 +120,8 @@ SmokeTestDriver.Verification
cadonna commented on code in PR #19421:
URL: https://github.com/apache/kafka/pull/19421#discussion_r2037425707
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java:
##
@@ -1476,17 +1473,12 @@ private ConsumerRecords
pollRequests(final Duration
[
https://issues.apache.org/jira/browse/KAFKA-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17943230#comment-17943230
]
Alieh Saeedi commented on KAFKA-18288:
--
AK PR: https://github.com/apache/kafka/pull
[
https://issues.apache.org/jira/browse/KAFKA-19127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi reassigned KAFKA-19127:
Assignee: Alieh Saeedi
> Integration Test for Admin API-Driven Group-Level Streams Group
Alieh Saeedi created KAFKA-19127:
Summary: Integration Test for Admin API-Driven Group-Level Streams
Group Configuration Changes
Key: KAFKA-19127
URL: https://issues.apache.org/jira/browse/KAFKA-19127
[
https://issues.apache.org/jira/browse/KAFKA-19126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Adrian C. updated KAFKA-19126:
--
Attachment: log-dump-sample.txt
> Duplicate offsets written to log for different messages
> --
aliehsaeedii opened a new pull request, #19436:
URL: https://github.com/apache/kafka/pull/19436
This PR introduces integration tests for verifying
- altering configs
- `describe` output
for a streams group.
--
This is an automated message from the Apache Git Service.
To resp
[
https://issues.apache.org/jira/browse/KAFKA-18935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TengYao Chi resolved KAFKA-18935.
-
Resolution: Fixed
> Ensure brokers do not return null records in FetchResponse
> ---
[
https://issues.apache.org/jira/browse/KAFKA-18935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TengYao Chi updated KAFKA-18935:
Fix Version/s: 4.1.0
> Ensure brokers do not return null records in FetchResponse
> --
frankvicky merged PR #19278:
URL: https://github.com/apache/kafka/pull/19278
--
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.apac
Yunyung commented on code in PR #19286:
URL: https://github.com/apache/kafka/pull/19286#discussion_r2037631639
##
server/src/test/java/org/apache/kafka/server/MonitorablePluginsIntegrationTest.java:
##
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
[
https://issues.apache.org/jira/browse/KAFKA-18920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-18920:
---
Fix Version/s: 3.9.1
> The kcontrollers do not set kraft.version in
FrankYang0529 opened a new pull request, #19439:
URL: https://github.com/apache/kafka/pull/19439
Both AddPartitionsToTxnConfig and TransactionStateManagerConfig are static
configs and they don't have specific config check. We can move them out of
KafkaConfig to simplify KafkaConfig.
--
T
[
https://issues.apache.org/jira/browse/KAFKA-18147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-18147:
---
Fix Version/s: (was: 3.9.1)
> kraft version of standalone KIP-85
[
https://issues.apache.org/jira/browse/KAFKA-18147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio resolved KAFKA-18147.
Resolution: Duplicate
> kraft version of standalone KIP-853. contr
[
https://issues.apache.org/jira/browse/KAFKA-18602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17943272#comment-17943272
]
José Armando García Sancio commented on KAFKA-18602:
Hi [~abasilbr]
Parkerhiphop commented on code in PR #19374:
URL: https://github.com/apache/kafka/pull/19374#discussion_r2035827481
##
core/src/main/scala/kafka/network/SocketServer.scala:
##
@@ -97,7 +97,7 @@ class SocketServer(
private val memoryPool = if (config.queuedMaxBytes > 0) new
S
AndrewJSchofield commented on code in PR #19378:
URL: https://github.com/apache/kafka/pull/19378#discussion_r2037776176
##
clients/src/main/java/org/apache/kafka/common/requests/AlterShareGroupOffsetsRequest.java:
##
@@ -41,7 +41,7 @@ public static class Builder extends
Abstrac
FrankYang0529 commented on PR #18685:
URL: https://github.com/apache/kafka/pull/18685#issuecomment-2794262999
Close the PR since the issue is fixed by
https://github.com/apache/kafka/pull/19127.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
AndrewJSchofield commented on PR #19432:
URL: https://github.com/apache/kafka/pull/19432#issuecomment-2792252728
@smjn Looks like the test failures are related.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
[
https://issues.apache.org/jira/browse/KAFKA-18602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17943278#comment-17943278
]
PoAn Yang commented on KAFKA-18602:
---
Yes, I think we can close this. Thanks.
> Incorr
[
https://issues.apache.org/jira/browse/KAFKA-17541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal reassigned KAFKA-17541:
-
Assignee: (was: Lan Ding)
> Improve handling of delivery count
> --
[
https://issues.apache.org/jira/browse/KAFKA-17541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal reassigned KAFKA-17541:
-
Assignee: Lan Ding
> Improve handling of delivery count
> -
FrankYang0529 closed pull request #18685: KAFKA-18602: Incorrect
FinalizedVersionLevel reported for dynamic KRaft quorum
URL: https://github.com/apache/kafka/pull/18685
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
Yunyung commented on code in PR #19286:
URL: https://github.com/apache/kafka/pull/19286#discussion_r2037634583
##
core/src/main/scala/kafka/server/BrokerServer.scala:
##
@@ -473,22 +473,7 @@ class BrokerServer(
config.numIoThreads,
s"${DataPlaneAcceptor.MetricPrefix}Re
Adrian C. created KAFKA-19126:
-
Summary: Duplicate offsets written to log for different messages
Key: KAFKA-19126
URL: https://issues.apache.org/jira/browse/KAFKA-19126
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-19126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Adrian C. updated KAFKA-19126:
--
Attachment: follower-error.log
> Duplicate offsets written to log for different messages
> ---
cadonna commented on PR #19421:
URL: https://github.com/apache/kafka/pull/19421#issuecomment-2794033244
@lucasbru The PR is 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 above to go t
lucasbru merged PR #19425:
URL: https://github.com/apache/kafka/pull/19425
--
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
frankvicky merged PR #19167:
URL: https://github.com/apache/kafka/pull/19167
--
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.apac
lucasbru opened a new pull request, #19438:
URL: https://github.com/apache/kafka/pull/19438
Enable KIP-1071 parameter in `StandbyTaskCreationIntegrationTest`.
Required a fix: In `ChangelogTopic.setup`, we actually need to return both
the source-topic (optimized) and the non-source-top
AndrewJSchofield merged PR #19432:
URL: https://github.com/apache/kafka/pull/19432
--
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...@kafk
AndrewJSchofield commented on code in PR #19378:
URL: https://github.com/apache/kafka/pull/19378#discussion_r2037371932
##
clients/src/main/resources/common/message/ShareAcknowledgeRequest.json:
##
@@ -18,34 +18,33 @@
"type": "request",
"listeners": ["broker"],
"name":
cadonna commented on code in PR #19421:
URL: https://github.com/apache/kafka/pull/19421#discussion_r2037419003
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java:
##
@@ -1108,7 +1090,20 @@ private void subscribeConsumer() {
if (topol
junrao commented on code in PR #19387:
URL: https://github.com/apache/kafka/pull/19387#discussion_r2037829585
##
storage/src/main/java/org/apache/kafka/storage/internals/log/Cleaner.java:
##
@@ -0,0 +1,762 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
apoorvmittal10 commented on code in PR #19378:
URL: https://github.com/apache/kafka/pull/19378#discussion_r2037882487
##
clients/src/main/resources/common/message/ShareAcknowledgeResponse.json:
##
@@ -17,7 +17,10 @@
"apiKey": 79,
"type": "response",
"name": "ShareAcknow
smjn opened a new pull request, #19432:
URL: https://github.com/apache/kafka/pull/19432
* We wish to track the time of creation of the `ShareSnapshot` records so
that automated jobs could force their creation if a share partition has gone
cold (no updates for a specified time interval).
smjn commented on code in PR #19431:
URL: https://github.com/apache/kafka/pull/19431#discussion_r2036832379
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -1248,29 +1248,118 @@ private CompletableFuture>
persisterDelete
smjn commented on code in PR #19431:
URL: https://github.com/apache/kafka/pull/19431#discussion_r2036833556
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -1248,29 +1248,118 @@ private CompletableFuture>
persisterDelete
mimaison commented on code in PR #19068:
URL: https://github.com/apache/kafka/pull/19068#discussion_r2032881917
##
core/src/main/java/kafka/server/QuotaFactory.java:
##
@@ -113,22 +116,43 @@ public void shutdown() {
}
}
-public static QuotaManagers instantiat
cadonna commented on PR #19421:
URL: https://github.com/apache/kafka/pull/19421#issuecomment-2792233359
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
lucasbru commented on code in PR #19421:
URL: https://github.com/apache/kafka/pull/19421#discussion_r2037145316
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -180,6 +186,25 @@ public class AsyncKafkaConsumer implements
Consu
lucasbru commented on code in PR #19421:
URL: https://github.com/apache/kafka/pull/19421#discussion_r2037149394
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceListener.java:
##
@@ -22,7 +22,7 @@
/**
* Callbacks for handling Streams group
lucasbru merged PR #19434:
URL: https://github.com/apache/kafka/pull/19434
--
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
FrankYang0529 commented on code in PR #19425:
URL: https://github.com/apache/kafka/pull/19425#discussion_r2037183291
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java:
##
@@ -140,6 +140,19 @@ public EmbeddedKafkaClust
FrankYang0529 commented on PR #19426:
URL: https://github.com/apache/kafka/pull/19426#issuecomment-2792534955
The failed case `DefaultApiVersionManagerTest#testApiScope` can be fixed
like:
```scala
@ParameterizedTest
@EnumSource(classOf[ListenerType])
def testApiScope(a
AndrewJSchofield commented on code in PR #19432:
URL: https://github.com/apache/kafka/pull/19432#discussion_r2037227861
##
share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareGroupOffset.java:
##
@@ -81,42 +98,63 @@ private static PersisterStateBatch
toPersi
frankvicky commented on code in PR #19420:
URL: https://github.com/apache/kafka/pull/19420#discussion_r2036739225
##
docker/README.md:
##
@@ -27,11 +27,11 @@ Building image and running tests using github actions
- This is the recommended way to build, test and get a CVE report
AndrewJSchofield merged PR #19261:
URL: https://github.com/apache/kafka/pull/19261
--
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...@kafk
[
https://issues.apache.org/jira/browse/KAFKA-16729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Schofield resolved KAFKA-16729.
--
Fix Version/s: 4.1.0
Resolution: Fixed
> Support for read-committed isolation l
smjn commented on code in PR #19431:
URL: https://github.com/apache/kafka/pull/19431#discussion_r2036837458
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -1248,29 +1248,118 @@ private CompletableFuture>
persisterDelete
smjn commented on code in PR #19431:
URL: https://github.com/apache/kafka/pull/19431#discussion_r2036835235
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -1248,29 +1248,118 @@ private CompletableFuture>
persisterDelete
smjn commented on code in PR #19431:
URL: https://github.com/apache/kafka/pull/19431#discussion_r2036832379
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -1248,29 +1248,118 @@ private CompletableFuture>
persisterDelete
smjn commented on code in PR #19431:
URL: https://github.com/apache/kafka/pull/19431#discussion_r2036835235
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -1248,29 +1248,118 @@ private CompletableFuture>
persisterDelete
johnny94 commented on code in PR #19420:
URL: https://github.com/apache/kafka/pull/19420#discussion_r2036843945
##
docker/README.md:
##
@@ -27,11 +27,11 @@ Building image and running tests using github actions
- This is the recommended way to build, test and get a CVE report fo
[
https://issues.apache.org/jira/browse/KAFKA-18287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi resolved KAFKA-18287.
--
Resolution: Fixed
https://github.com/apache/kafka/pull/19422
> Add support for kafka-streams-
aliehsaeedii opened a new pull request, #19433:
URL: https://github.com/apache/kafka/pull/19433
Implement `--describe` and its options: (`--state`, -`-offset`, `--members`
and the combination of them with `--verbose`) as described in `KIP-1071`.
--
This is an automated message from th
[ https://issues.apache.org/jira/browse/KAFKA-18287 ]
Alieh Saeedi deleted comment on KAFKA-18287:
--
was (Author: JIRAUSER298811):
https://github.com/apache/kafka/pull/19422
> Add support for kafka-streams-groups.sh --list
> ---
mimaison commented on code in PR #19395:
URL: https://github.com/apache/kafka/pull/19395#discussion_r2032004110
##
server/src/test/java/org/apache/kafka/network/SocketServerConfigsTest.java:
##
@@ -22,8 +22,8 @@
import org.junit.jupiter.api.Test;
-import java.util.Arrays;
cadonna merged PR #19377:
URL: https://github.com/apache/kafka/pull/19377
--
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.
apoorvmittal10 commented on code in PR #19378:
URL: https://github.com/apache/kafka/pull/19378#discussion_r2037943935
##
clients/src/main/resources/common/message/ShareAcknowledgeResponse.json:
##
@@ -17,7 +17,10 @@
"apiKey": 79,
"type": "response",
"name": "ShareAcknow
[
https://issues.apache.org/jira/browse/KAFKA-19108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-19108:
---
Priority: Minor (was: Major)
> Consider improving the UI when descr
m1a2st commented on code in PR #19397:
URL: https://github.com/apache/kafka/pull/19397#discussion_r2033053426
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java:
##
@@ -269,18 +270,19 @@ List configProviders() {
Map transform(Map props) {
OmniaGM commented on code in PR #15968:
URL: https://github.com/apache/kafka/pull/15968#discussion_r2035281152
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -390,57 +390,72 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
-val unauthorize
chia7712 commented on code in PR #19384:
URL: https://github.com/apache/kafka/pull/19384#discussion_r2032855809
##
core/src/main/scala/kafka/server/KafkaRequestHandler.scala:
##
@@ -208,7 +208,7 @@ class KafkaRequestHandlerPool(
/* a meter to track the average free capacity o
apoorvmittal10 commented on code in PR #19378:
URL: https://github.com/apache/kafka/pull/19378#discussion_r2037973763
##
clients/src/main/resources/common/message/ShareAcknowledgeResponse.json:
##
@@ -17,7 +17,10 @@
"apiKey": 79,
"type": "response",
"name": "ShareAcknow
Ravi Kalasapur created KAFKA-19117:
--
Summary: Client Throttling Log messages should be of log level -
WARN
Key: KAFKA-19117
URL: https://issues.apache.org/jira/browse/KAFKA-19117
Project: Kafka
apoorvmittal10 commented on code in PR #19378:
URL: https://github.com/apache/kafka/pull/19378#discussion_r2037943935
##
clients/src/main/resources/common/message/ShareAcknowledgeResponse.json:
##
@@ -17,7 +17,10 @@
"apiKey": 79,
"type": "response",
"name": "ShareAcknow
apoorvmittal10 commented on code in PR #19378:
URL: https://github.com/apache/kafka/pull/19378#discussion_r2037944799
##
clients/src/main/resources/common/message/ShareFetchRequest.json:
##
@@ -48,6 +47,8 @@
"about": "The partitions to fetch.", "fields": [
{ "n
smjn commented on code in PR #19431:
URL: https://github.com/apache/kafka/pull/19431#discussion_r2036832379
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -1248,29 +1248,118 @@ private CompletableFuture>
persisterDelete
apoorvmittal10 commented on code in PR #19378:
URL: https://github.com/apache/kafka/pull/19378#discussion_r2037892822
##
clients/src/main/resources/common/message/ShareFetchRequest.json:
##
@@ -48,6 +47,8 @@
"about": "The partitions to fetch.", "fields": [
{ "n
[
https://issues.apache.org/jira/browse/KAFKA-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang reassigned KAFKA-19121:
-
Assignee: PoAn Yang (was: Chia-Ping Tsai)
> Move AddPartitionsToTxnConfig, TransactionStateMan
chia7712 merged PR #19401:
URL: https://github.com/apache/kafka/pull/19401
--
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
José Armando García Sancio created KAFKA-19108:
--
Summary: Consider improving the UI when describing static voters
Key: KAFKA-19108
URL: https://issues.apache.org/jira/browse/KAFKA-19108
Pr
wernerdv commented on code in PR #19387:
URL: https://github.com/apache/kafka/pull/19387#discussion_r2032560885
##
storage/src/main/java/org/apache/kafka/storage/internals/log/CleanedTransactionMetadata.java:
##
@@ -0,0 +1,160 @@
+/*
+ * Licensed to the Apache Software Foundatio
TaiJuWu commented on code in PR #19286:
URL: https://github.com/apache/kafka/pull/19286#discussion_r2037597964
##
server/src/test/java/org/apache/kafka/server/MonitorablePluginsIntegrationTest.java:
##
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
AndrewJSchofield commented on code in PR #19378:
URL: https://github.com/apache/kafka/pull/19378#discussion_r2037929838
##
clients/src/main/resources/common/message/ShareFetchRequest.json:
##
@@ -48,6 +47,8 @@
"about": "The partitions to fetch.", "fields": [
{
AndrewJSchofield commented on PR #19430:
URL: https://github.com/apache/kafka/pull/19430#issuecomment-2794085366
@DL1231 Looks like a compile failure.
--
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
AndrewJSchofield commented on code in PR #19378:
URL: https://github.com/apache/kafka/pull/19378#discussion_r2037938413
##
clients/src/main/resources/common/message/ShareAcknowledgeResponse.json:
##
@@ -17,7 +17,10 @@
"apiKey": 79,
"type": "response",
"name": "ShareAckn
黃竣陽 created KAFKA-19111:
---
Summary: Remove ModernGroup#computeSubscriptionMetadata unused
parameter
Key: KAFKA-19111
URL: https://issues.apache.org/jira/browse/KAFKA-19111
Project: Kafka
Issue Type: Im
wernerdv commented on code in PR #19387:
URL: https://github.com/apache/kafka/pull/19387#discussion_r2034777548
##
storage/src/main/java/org/apache/kafka/storage/internals/log/Cleaner.java:
##
@@ -0,0 +1,762 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one o
junrao commented on PR #19371:
URL: https://github.com/apache/kafka/pull/19371#issuecomment-2787910437
@m1a2st : Perhaps we could somehow allow the tests to set a small
`segment.bytes`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
junrao commented on code in PR #15968:
URL: https://github.com/apache/kafka/pull/15968#discussion_r2032049630
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -108,7 +108,7 @@ class KafkaApis(val requestChannel: RequestChannel,
val groupConfigManager:
mimaison commented on code in PR #19050:
URL: https://github.com/apache/kafka/pull/19050#discussion_r2031382775
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -3284,7 +3285,7 @@ private boolean maybeUpdateRegularExpressions
junrao commented on code in PR #19293:
URL: https://github.com/apache/kafka/pull/19293#discussion_r2037984758
##
core/src/test/scala/unit/kafka/server/AbstractApiVersionsRequestTest.scala:
##
@@ -85,6 +85,9 @@ abstract class AbstractApiVersionsRequestTest(cluster:
ClusterInstan
[
https://issues.apache.org/jira/browse/KAFKA-19126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Adrian C. updated KAFKA-19126:
--
Description:
We have observed during normal operations that messages/batches can be written
to disk w
1 - 100 of 187 matches
Mail list logo
