[
https://issues.apache.org/jira/browse/KAFKA-19084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shivsundar R reassigned KAFKA-19084:
Assignee: Shivsundar R
> Port KAFKA-16224 for acknowledgements in ShareConsumers.
> -
Shivsundar R created KAFKA-19084:
Summary: Port KAFKA-16224 for acknowledgements in ShareConsumers.
Key: KAFKA-19084
URL: https://issues.apache.org/jira/browse/KAFKA-19084
Project: Kafka
Issu
ShivsundarR opened a new pull request, #19369:
URL: https://github.com/apache/kafka/pull/19369
*What*
Currently for ShareConsumers, if we receive an `UNKNOWN_TOPIC_OR_PARTITION`
error code in the `ShareAcknowledgeResponse`, then we retry sending the
acknowledgements until the timer expir
lucasbru commented on code in PR #19359:
URL: https://github.com/apache/kafka/pull/19359#discussion_r2028433315
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java:
##
@@ -197,6 +197,13 @@ public static class DeadlineAndEpoch {
*
lucasbru commented on code in PR #19359:
URL: https://github.com/apache/kafka/pull/19359#discussion_r2028429508
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -2070,8 +2067,6 @@ private CoordinatorResult stream
Str
lucasbru commented on code in PR #19359:
URL: https://github.com/apache/kafka/pull/19359#discussion_r2028433315
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java:
##
@@ -197,6 +197,13 @@ public static class DeadlineAndEpoch {
*
adixitconfluent opened a new pull request, #19370:
URL: https://github.com/apache/kafka/pull/19370
### What
The tests testMultipleConcurrentShareFetches is throwing a silent exception.
ERROR Error processing delayed share fetch request
(kafka.server.share.DelayedShareFetch:225)
lucasbru commented on code in PR #19359:
URL: https://github.com/apache/kafka/pull/19359#discussion_r2028446403
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -16233,6 +16233,97 @@ public void
testStreamsGroupMemberJoi
m1a2st opened a new pull request, #19371:
URL: https://github.com/apache/kafka/pull/19371
The main reason is that we forgot setting the
`TopicConfig.SEGMENT_BYTES_CONFIG` at least to `1024 * 1024`, thus addressed
it, and add a test for it.
--
This is an automated message from the Apache
AndrewJSchofield commented on PR #18976:
URL: https://github.com/apache/kafka/pull/18976#issuecomment-2778570067
@chirag-wadhwa5 Please could you resolve the conflicts.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
Andrew Schofield created KAFKA-19081:
Summary: Share session capacity and eviction
Key: KAFKA-19081
URL: https://issues.apache.org/jira/browse/KAFKA-19081
Project: Kafka
Issue Type: Sub-t
sjhajharia opened a new pull request, #19372:
URL: https://github.com/apache/kafka/pull/19372
Now that Kafka Brokers support Java 17, this PR makes some changes in core
module. The changes in this PR are limited to only the Java files in the Core
module. Scala related changes may follow nex
lucasbru commented on code in PR #19219:
URL: https://github.com/apache/kafka/pull/19219#discussion_r2028521537
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -18070,6 +18241,101 @@ public void testShareGroupDynamicConf
lucasbru commented on code in PR #19219:
URL: https://github.com/apache/kafka/pull/19219#discussion_r2028522022
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -18070,6 +18241,101 @@ public void testShareGroupDynamicConf
lucasbru commented on code in PR #19359:
URL: https://github.com/apache/kafka/pull/19359#discussion_r2028446631
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsGroupTest.java:
##
@@ -1106,4 +1106,32 @@ public void testIsSubscribedToTopic() {
lucasbru commented on code in PR #19219:
URL: https://github.com/apache/kafka/pull/19219#discussion_r2028522552
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -15776,6 +15779,76 @@ public void testStreamsGroupMemberEpoc
mimaison commented on code in PR #19286:
URL: https://github.com/apache/kafka/pull/19286#discussion_r2027343207
##
core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java:
##
@@ -413,24 +418,19 @@ void
testRemoteLogMetadataManagerWithEndpointConfigOverridden() throws IOEx
FrankYang0529 commented on code in PR #19357:
URL: https://github.com/apache/kafka/pull/19357#discussion_r2028360352
##
server/src/test/java/org/apache/kafka/server/share/fetch/ShareFetchTest.java:
##
@@ -66,6 +79,19 @@ public void testErrorInAllPartitions() {
assertTru
AndrewJSchofield commented on code in PR #19328:
URL: https://github.com/apache/kafka/pull/19328#discussion_r2028378471
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -1365,6 +1368,67 @@ public
CompletableFuture
descri
AndrewJSchofield merged PR #19358:
URL: https://github.com/apache/kafka/pull/19358
--
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
chia7712 commented on code in PR #19285:
URL: https://github.com/apache/kafka/pull/19285#discussion_r2028502006
##
storage/src/main/java/org/apache/kafka/server/purgatory/DelayedRemoteListOffsets.java:
##
@@ -0,0 +1,200 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
lucasbru commented on PR #19359:
URL: https://github.com/apache/kafka/pull/19359#issuecomment-2778072098
@mjsax @jeffkbkim Thanks for the comments! All 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
lucasbru commented on code in PR #19219:
URL: https://github.com/apache/kafka/pull/19219#discussion_r2028511160
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/MockTaskAssignor.java:
##
@@ -60,6 +65,7 @@ public String name() {
@Override
pu
Pritam Kumar created KAFKA-19086:
Summary: Extending support for Microsecond Precision for Kafka
Connect
Key: KAFKA-19086
URL: https://issues.apache.org/jira/browse/KAFKA-19086
Project: Kafka
FrankYang0529 commented on code in PR #19362:
URL: https://github.com/apache/kafka/pull/19362#discussion_r2028331394
##
tests/kafkatest/services/verifiable_producer.py:
##
@@ -147,9 +147,10 @@ def _worker(self, idx, node):
if self.enable_idempotence:
self.l
squah-confluent opened a new pull request, #19260:
URL: https://github.com/apache/kafka/pull/19260
Introduce a buffer reuse mechanism for LZ4 compression, similar to the
ones Snappy and zstd compression have.
--
This is an automated message from the Apache Git Service.
To respon
jeqo commented on PR #19150:
URL: https://github.com/apache/kafka/pull/19150#issuecomment-2768303521
Opened https://github.com/apache/kafka/pull/19331 for 4.0 backport
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
chia7712 commented on code in PR #18711:
URL: https://github.com/apache/kafka/pull/18711#discussion_r2008102525
##
server-common/src/main/java/org/apache/kafka/server/config/ConfigType.java:
##
@@ -16,19 +16,30 @@
*/
package org.apache.kafka.server.config;
+import java.util
chia7712 merged PR #19301:
URL: https://github.com/apache/kafka/pull/19301
--
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-19087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Yi Chang reassigned KAFKA-19087:
--
Assignee: Cheng Yi Chang (was: Chia-Ping Tsai)
> Move TransactionState to transactio
chia7712 merged PR #19367:
URL: https://github.com/apache/kafka/pull/19367
--
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
OmniaGM commented on PR #15968:
URL: https://github.com/apache/kafka/pull/15968#issuecomment-2778290434
> That's great, thanks!
@ijuma and @jolshan I fixed the conflicts now
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
[
https://issues.apache.org/jira/browse/KAFKA-19087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940938#comment-17940938
]
Chia-Ping Tsai commented on KAFKA-19087:
Maybe we should consider leveraging `Tr
lucasbru commented on code in PR #19219:
URL: https://github.com/apache/kafka/pull/19219#discussion_r2028472624
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -8148,7 +8174,10 @@ private TaskAssignor streamsGroupAssignor(St
Chia-Ping Tsai created KAFKA-19088:
--
Summary: Consider logging the unknownStateFilters when listing
transation ids
Key: KAFKA-19088
URL: https://issues.apache.org/jira/browse/KAFKA-19088
Project: Kaf
AndrewJSchofield merged PR #19328:
URL: https://github.com/apache/kafka/pull/19328
--
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-19088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940959#comment-17940959
]
Jhen-Yung Hsu commented on KAFKA-19088:
---
Hi, I'm working on this, thanks. :)
> Co
[
https://issues.apache.org/jira/browse/KAFKA-19088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jhen-Yung Hsu reassigned KAFKA-19088:
-
Assignee: Jhen-Yung Hsu (was: Chia-Ping Tsai)
> Consider logging the unknownStateFilte
Andrew Schofield created KAFKA-19031:
Summary: Ensure brokers do not return null records in
ShareFetchResponse
Key: KAFKA-19031
URL: https://issues.apache.org/jira/browse/KAFKA-19031
Project: Kafk
OmniaGM commented on PR #15968:
URL: https://github.com/apache/kafka/pull/15968#issuecomment-2773053998
> @OmniaGM Would you like someone to help get this over the finish line?
I am nearly done with fixing the conflict should publish this this week.
sorry for late replay I have been a
sjhajharia commented on PR #19372:
URL: https://github.com/apache/kafka/pull/19372#issuecomment-2779234357
Thanks @m1a2st for the review.
I have addressed the comments and pushed a fresh commit. Pls review when
possible.
--
This is an automated message from the Apache Git Service.
To r
adixitconfluent commented on PR #19261:
URL: https://github.com/apache/kafka/pull/19261#issuecomment-2774680482
> Thanks for the updates. In general, I'm happy with the PR, with the
exception of the `filterRecordBatchesFromAcquiredRecords` method. It needs much
more comprehensive commenting
Abhinav Dixit created KAFKA-19085:
-
Summary: SharePartitionManagerTest
testMultipleConcurrentShareFetches throws silent exception and works incorrectly
Key: KAFKA-19085
URL: https://issues.apache.org/jira/browse/K
junrao commented on code in PR #19167:
URL: https://github.com/apache/kafka/pull/19167#discussion_r2025673505
##
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java:
##
@@ -87,7 +87,7 @@ public FetchResponseData data() {
* We may also return INCONSIST
[
https://issues.apache.org/jira/browse/KAFKA-19066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940079#comment-17940079
]
Chia-Ping Tsai commented on KAFKA-19066:
related to https://github.com/apache/ka
Chia-Ping Tsai created KAFKA-19087:
--
Summary: Move TransactionState to transaction-coordinator module
Key: KAFKA-19087
URL: https://issues.apache.org/jira/browse/KAFKA-19087
Project: Kafka
I
chirag-wadhwa5 commented on PR #18976:
URL: https://github.com/apache/kafka/pull/18976#issuecomment-2778711584
Hi @AndrewJSchofield, I have resolved the conflicts. The PR is ready for
another round of review. Thanks !
--
This is an automated message from the Apache Git Service.
To respond
m1a2st commented on code in PR #19375:
URL: https://github.com/apache/kafka/pull/19375#discussion_r2028926018
##
core/src/test/scala/unit/kafka/log/LogManagerTest.scala:
##
@@ -147,7 +150,10 @@ class LogManagerTest {
assertEquals(1, logManager.liveLogDirs.size)
val log
frankvicky commented on code in PR #19376:
URL: https://github.com/apache/kafka/pull/19376#discussion_r2029040633
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -3664,7 +3664,6 @@ public void testFetcherDontCacheAnyData() {
cadonna opened a new pull request, #19377:
URL: https://github.com/apache/kafka/pull/19377
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
trnguyencflt commented on code in PR #19353:
URL: https://github.com/apache/kafka/pull/19353#discussion_r2029055199
##
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java:
##
@@ -51,8 +53,8 @@ final ByteBuffer serializeWithHeader(ResponseHeader header,
trnguyencflt commented on PR #19353:
URL: https://github.com/apache/kafka/pull/19353#issuecomment-2779128261
[nit] Please remove this block "Delete this text " from the description
of the PR.
Otherwise, LGTM
--
This is an automated message from the Apache Git Service.
To respon
[
https://issues.apache.org/jira/browse/KAFKA-19089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-19089:
--
Assignee: Chia-Ping Tsai
> Gradle :test task failing unexpectedly
> -
m1a2st opened a new pull request, #19375:
URL: https://github.com/apache/kafka/pull/19375
Some parameter is unused and fix assertion
--
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
lucasbru merged PR #19373:
URL: https://github.com/apache/kafka/pull/19373
--
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
m1a2st commented on PR #19371:
URL: https://github.com/apache/kafka/pull/19371#issuecomment-2778790334
Hello @junrao, @chia7712
I have a question about this problem.
In
[[KAFKA-16368](https://github.com/apache/kafka/pull/18140/files)](https://github.com/apache/kafka/pull/18140/files),
TaiJuWu commented on code in PR #19357:
URL: https://github.com/apache/kafka/pull/19357#discussion_r2029013870
##
server/src/test/java/org/apache/kafka/server/share/fetch/ShareFetchTest.java:
##
@@ -43,11 +52,15 @@ public class ShareFetchTest {
private static final String M
Parkerhiphop commented on code in PR #16532:
URL: https://github.com/apache/kafka/pull/16532#discussion_r2029035269
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -3665,6 +3670,18 @@ public void
testWhenFetchResponseReturnsALeaderSh
Parkerhiphop commented on code in PR #16532:
URL: https://github.com/apache/kafka/pull/16532#discussion_r2029035269
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -3665,6 +3670,18 @@ public void
testWhenFetchResponseReturnsALeaderSh
cadonna opened a new pull request, #19373:
URL: https://github.com/apache/kafka/pull/19373
With the Streams rebalance protocol, when the partition count
for changelog topics are computed the topic manager only
considers external source topics and throws if there are no
source topics
m1a2st commented on code in PR #19376:
URL: https://github.com/apache/kafka/pull/19376#discussion_r2029039303
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -3664,7 +3664,6 @@ public void testFetcherDontCacheAnyData() {
resp
Parkerhiphop opened a new pull request, #19376:
URL: https://github.com/apache/kafka/pull/19376
This is from [#16532's
comment](https://github.com/apache/kafka/pull/16532/files#r2028985028):
The forEach loop in the assertion will never execute because
`nonResponseData` is empty.
chia7712 commented on code in PR #19376:
URL: https://github.com/apache/kafka/pull/19376#discussion_r2029039198
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -3664,7 +3664,6 @@ public void testFetcherDontCacheAnyData() {
re
Parkerhiphop opened a new pull request, #19374:
URL: https://github.com/apache/kafka/pull/19374
As described in the JIRA ticket, controlPlaneRequestChannelOpt was removed
from KRaft mode, so there's no need to use the metrics prefix anymore.
This change removes `metricNamePrefix` from
FrankYang0529 commented on code in PR #16532:
URL: https://github.com/apache/kafka/pull/16532#discussion_r2028985028
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -3665,6 +3670,18 @@ public void
testWhenFetchResponseReturnsALeaderS
FrankYang0529 commented on code in PR #19357:
URL: https://github.com/apache/kafka/pull/19357#discussion_r2028994700
##
server/src/test/java/org/apache/kafka/server/share/fetch/ShareFetchTest.java:
##
@@ -43,11 +52,15 @@ public class ShareFetchTest {
private static final St
soarez merged PR #19351:
URL: https://github.com/apache/kafka/pull/19351
--
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
m1a2st commented on code in PR #19372:
URL: https://github.com/apache/kafka/pull/19372#discussion_r2029065027
##
core/src/main/java/kafka/server/share/SharePartitionManager.java:
##
@@ -357,7 +356,7 @@ public CompletableFuture {
return isrSize == 0 && elrSize ==
Parkerhiphop commented on code in PR #19376:
URL: https://github.com/apache/kafka/pull/19376#discussion_r2029101369
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -3664,7 +3664,6 @@ public void testFetcherDontCacheAnyData() {
chia7712 merged PR #19365:
URL: https://github.com/apache/kafka/pull/19365
--
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
Parkerhiphop commented on code in PR #19376:
URL: https://github.com/apache/kafka/pull/19376#discussion_r2029102952
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -3664,7 +3664,6 @@ public void testFetcherDontCacheAnyData() {
chia7712 commented on code in PR #16532:
URL: https://github.com/apache/kafka/pull/16532#discussion_r2028993496
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -3665,6 +3670,18 @@ public void
testWhenFetchResponseReturnsALeaderShipCh
David Arthur created KAFKA-19089:
Summary: Gradle :test task failing unexpectedly
Key: KAFKA-19089
URL: https://issues.apache.org/jira/browse/KAFKA-19089
Project: Kafka
Issue Type: Bug
mjsax merged PR #19218:
URL: https://github.com/apache/kafka/pull/19218
--
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.or
frankvicky commented on code in PR #17614:
URL: https://github.com/apache/kafka/pull/17614#discussion_r2029109982
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractHeartbeatRequestManager.java:
##
@@ -182,7 +181,7 @@ public NetworkClientDelegate.PollRe
kumarpritam863 commented on PR #19341:
URL: https://github.com/apache/kafka/pull/19341#issuecomment-2779267375
Hi @mimaison can you please review this. Thanks.
--
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
lucasbru merged PR #19360:
URL: https://github.com/apache/kafka/pull/19360
--
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 commented on code in PR #19376:
URL: https://github.com/apache/kafka/pull/19376#discussion_r2029047826
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -3664,7 +3664,6 @@ public void testFetcherDontCacheAnyData() {
Parkerhiphop commented on code in PR #19374:
URL: https://github.com/apache/kafka/pull/19374#discussion_r2028918289
##
core/src/main/scala/kafka/network/RequestChannel.scala:
##
@@ -349,8 +348,8 @@ class RequestChannel(val queueSize: Int,
private val requestQueue = new Arra
lucasbru commented on code in PR #19359:
URL: https://github.com/apache/kafka/pull/19359#discussion_r2028433315
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java:
##
@@ -197,6 +197,13 @@ public static class DeadlineAndEpoch {
*
soondenana commented on code in PR #19353:
URL: https://github.com/apache/kafka/pull/19353#discussion_r2029166476
##
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java:
##
@@ -51,8 +53,8 @@ final ByteBuffer serializeWithHeader(ResponseHeader header,
sh
AndrewJSchofield opened a new pull request, #19378:
URL: https://github.com/apache/kafka/pull/19378
This PR removes the unstable API flag for the KIP-932 RPCs.
The 4 RPCs which were exposed for the early access release in AK 4.0 are
stabilised at v1. This is because the RPCs have evol
[
https://issues.apache.org/jira/browse/KAFKA-19073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Calvin Liu updated KAFKA-19073:
---
Summary: Add Transactional ID pattern filter to ListTransactions API (was:
Add Transactional ID pre
[
https://issues.apache.org/jira/browse/KAFKA-18761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Schofield resolved KAFKA-18761.
--
Resolution: Fixed
> kafka-share-groups.sh --describe only shows offset information whe
[
https://issues.apache.org/jira/browse/KAFKA-18902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Schofield reassigned KAFKA-18902:
Assignee: Shivsundar R (was: Andrew Schofield)
> Implement ShareConsumer option
[
https://issues.apache.org/jira/browse/KAFKA-19089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-19089:
-
Component/s: build
> Gradle :test task failing unexpectedly
> --
m1a2st commented on PR #19068:
URL: https://github.com/apache/kafka/pull/19068#issuecomment-2777484507
Thanks for @mimaison review, addressed all comments
--
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 t
TaiJuWu commented on code in PR #19286:
URL: https://github.com/apache/kafka/pull/19286#discussion_r2022590789
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -407,14 +413,17 @@ private void configureRLMM() {
rlmmProps.put(LOG_DIR_CONFIG, logDir);
ableegoldman commented on code in PR #17614:
URL: https://github.com/apache/kafka/pull/17614#discussion_r2025873637
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerHeartbeatRequestManager.java:
##
@@ -211,6 +214,28 @@ public ConsumerMembershipManager
adixitconfluent commented on code in PR #19261:
URL: https://github.com/apache/kafka/pull/19261#discussion_r2022946269
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -2484,6 +2504,205 @@ private long startOffsetDuringInitialization(long
partitionDataStartOf
frankvicky commented on code in PR #19167:
URL: https://github.com/apache/kafka/pull/19167#discussion_r2025822378
##
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java:
##
@@ -87,7 +87,7 @@ public FetchResponseData data() {
* We may also return INCON
[
https://issues.apache.org/jira/browse/KAFKA-19033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937947#comment-17937947
]
David Jacot commented on KAFKA-19033:
-
I alraedy have a patch for it: https://github
[
https://issues.apache.org/jira/browse/KAFKA-18900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Schofield reassigned KAFKA-18900:
Assignee: Shivsundar R (was: Andrew Schofield)
> Create a consumer config to sel
sjhajharia opened a new pull request, #19379:
URL: https://github.com/apache/kafka/pull/19379
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 c
sjhajharia closed pull request #19379: Cleanup core 2
URL: https://github.com/apache/kafka/pull/19379
--
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: ji
Parkerhiphop commented on code in PR #19376:
URL: https://github.com/apache/kafka/pull/19376#discussion_r2029097843
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -3663,8 +3663,7 @@ public void testFetcherDontCacheAnyData() {
TaiJuWu commented on code in PR #16532:
URL: https://github.com/apache/kafka/pull/16532#discussion_r2029018014
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -3665,6 +3670,18 @@ public void
testWhenFetchResponseReturnsALeaderShipCha
[
https://issues.apache.org/jira/browse/KAFKA-19079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941041#comment-17941041
]
Justine Olshan commented on KAFKA-19079:
[~iamoshione]
KIP-890 is a kafka impr
[
https://issues.apache.org/jira/browse/KAFKA-15758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-15758:
--
Assignee: David Jacot
> Always schedule wrapped callbacks
>
[
https://issues.apache.org/jira/browse/KAFKA-19073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Calvin Liu updated KAFKA-19073:
---
Description:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1152%3A+Add+transactional+ID+patt
1 - 100 of 239 matches
Mail list logo
