jlprat merged PR #17253:
URL: https://github.com/apache/kafka/pull/17253
--
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
jlprat commented on PR #17253:
URL: https://github.com/apache/kafka/pull/17253#issuecomment-2370343351
Tests passed on GH CI, and the 2 failures in Jenkins CI were known flaky
tests.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
[
https://issues.apache.org/jira/browse/KAFKA-15896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884128#comment-17884128
]
Josep Prat commented on KAFKA-15896:
Another instance:
https://ci-builds.apache.org
[
https://issues.apache.org/jira/browse/KAFKA-16491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884129#comment-17884129
]
Josep Prat commented on KAFKA-16491:
Another instance
https://ci-builds.apache.org/
lucasbru commented on code in PR #17091:
URL: https://github.com/apache/kafka/pull/17091#discussion_r1772726105
##
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java:
##
@@ -90,6 +91,15 @@ public int count() {
return count;
}
+public
lucasbru commented on code in PR #17091:
URL: https://github.com/apache/kafka/pull/17091#discussion_r1772723868
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java:
##
@@ -462,23 +463,29 @@ public Map
prepareCommit() {
}
}
-
lucasbru commented on code in PR #17091:
URL: https://github.com/apache/kafka/pull/17091#discussion_r1772721636
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -1820,6 +1820,9 @@ void addRecordsToTasks(final ConsumerRecords records)
tvainika opened a new pull request, #17261:
URL: https://github.com/apache/kafka/pull/17261
Remove too late check that prevents partition reassignment if
`segment.bytes` has been changed to smaller value than size of existing
message. Checks for `segment.bytes` limit should be only handled
edgarzubel closed pull request #16279: KAFKA-16848: Reverting KRaft migration
for "Migrating brokers to KRaft" state is wrong
URL: https://github.com/apache/kafka/pull/16279
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
frankvicky commented on code in PR #17250:
URL: https://github.com/apache/kafka/pull/17250#discussion_r1772580034
##
tests/kafkatest/tests/core/reassign_partitions_test.py:
##
@@ -176,7 +176,13 @@ def test_reassign_partitions(self, bounce_brokers,
reassign_from_offset_zero, me
TaiJuWu opened a new pull request, #17260:
URL: https://github.com/apache/kafka/pull/17260
Jira: https://issues.apache.org/jira/browse/KAFKA-17542
test on: https://github.com/TaiJuWu/kafka/pull/10
### Committer Checklist (excluded from commit message)
- [ ] Verify design and impl
[
https://issues.apache.org/jira/browse/KAFKA-4566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884103#comment-17884103
]
Alex Russell edited comment on KAFKA-4566 at 9/24/24 4:21 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-4566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884103#comment-17884103
]
Alex Russell commented on KAFKA-4566:
-
readlink -f appears to be equivalent on both (
[
https://issues.apache.org/jira/browse/KAFKA-17572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884099#comment-17884099
]
Chia-Ping Tsai commented on KAFKA-17572:
[~chiacyu] I have assigned this Jira to
[
https://issues.apache.org/jira/browse/KAFKA-17572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-17572:
--
Assignee: Chia-Chuan Yu
> Clear build scan PR status when re-running the tests
>
chia7712 commented on code in PR #17250:
URL: https://github.com/apache/kafka/pull/17250#discussion_r1772502096
##
tests/kafkatest/tests/core/reassign_partitions_test.py:
##
@@ -176,7 +176,13 @@ def test_reassign_partitions(self, bounce_brokers,
reassign_from_offset_zero, me
mjsax commented on code in PR #17259:
URL: https://github.com/apache/kafka/pull/17259#discussion_r1772482294
##
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java:
##
@@ -1780,13 +1781,24 @@ public Map
getGlobalConsumerConfigs(final String clientId) {
* @re
mjsax commented on code in PR #17259:
URL: https://github.com/apache/kafka/pull/17259#discussion_r1772483525
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java:
##
@@ -304,17 +291,11 @@ void closeAndRemoveTaskProducerIfNeeded(final TaskI
mjsax commented on code in PR #17259:
URL: https://github.com/apache/kafka/pull/17259#discussion_r1772482879
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java:
##
@@ -282,13 +270,12 @@ private StreamTask createActiveTask(final TaskId ta
mjsax commented on code in PR #17259:
URL: https://github.com/apache/kafka/pull/17259#discussion_r1772483810
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java:
##
@@ -76,7 +76,6 @@ public class RecordCollectorImpl implements RecordCol
mjsax commented on code in PR #17259:
URL: https://github.com/apache/kafka/pull/17259#discussion_r1772481861
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java:
##
@@ -58,10 +58,13 @@ class ActiveTaskCreator {
private final Time tim
[
https://issues.apache.org/jira/browse/KAFKA-17590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884086#comment-17884086
]
Fake commented on KAFKA-17590:
--
Additionally, the producer client has the following excepti
mjsax opened a new pull request, #17259:
URL: https://github.com/apache/kafka/pull/17259
With EOSv1 removed, we don't need to create a producer per task, and thus
can simplify the code by removing `KafkaClientSupplier` from the deeply nested
`StreamsProducer`, to simplify the code.
--
Th
mjsax commented on PR #17205:
URL: https://github.com/apache/kafka/pull/17205#issuecomment-2369989314
Thanks for the review @chia7712. Merged to `trunk`.
--
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
mjsax merged PR #17205:
URL: https://github.com/apache/kafka/pull/17205
--
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
mjsax commented on code in PR #17205:
URL: https://github.com/apache/kafka/pull/17205#discussion_r1772476886
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerdeTest.java:
##
@@ -73,68 +69,95 @@ public T deserialize(
mjsax commented on code in PR #17205:
URL: https://github.com/apache/kafka/pull/17205#discussion_r1772476702
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerdeTest.java:
##
@@ -73,68 +69,95 @@ public T deserialize(
[
https://issues.apache.org/jira/browse/KAFKA-17590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884078#comment-17884078
]
ChenLin edited comment on KAFKA-17590 at 9/24/24 2:05 AM:
--
# SS
[
https://issues.apache.org/jira/browse/KAFKA-17590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884078#comment-17884078
]
ChenLin commented on KAFKA-17590:
-
# SSL authentication is not enabled on the Kafka serv
mumrah commented on PR #17204:
URL: https://github.com/apache/kafka/pull/17204#issuecomment-2369931659
In the [checkout action](https://github.com/actions/checkout) you can
specify that you want a full checkout instead of sparse.
```
# Specifies whether to use cone-mode when d
[
https://issues.apache.org/jira/browse/KAFKA-17581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17581:
--
Component/s: clients
consumer
> AsyncKafkaConsumer can't unsubscribe invalid topics
>
fonsdant commented on PR #17204:
URL: https://github.com/apache/kafka/pull/17204#issuecomment-2369905530
@mumrah, forgive me if I am being too repetitive or slow to develop. I am
trying to achieve a great result to us and Kafka contributors.
I was afraid to proceed with merge approach
kirktrue commented on PR #17244:
URL: https://github.com/apache/kafka/pull/17244#issuecomment-2369893861
From the PR description:
> If AsyncKafkaConsumer subscribes an invalid topic, the background thread
will keep sending MetadataRequest with invalid topic, so background event queue
rich-c-shop commented on PR #17099:
URL: https://github.com/apache/kafka/pull/17099#issuecomment-2369884620
> continuous-integration/jenkins/pr-merge — This commit has test failures
Thanks for reviewing. looks like the test failed in un-related tests.
Anything I can help to proceed fo
jolshan commented on code in PR #16443:
URL: https://github.com/apache/kafka/pull/16443#discussion_r1772344230
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -2305,11 +2307,34 @@ public CompletableFuture
updateFeatures(
}).thenApply(
jolshan commented on code in PR #16443:
URL: https://github.com/apache/kafka/pull/16443#discussion_r1772343326
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -3603,13 +3603,16 @@ class KafkaApis(val requestChannel: RequestChannel,
def sendResponseCallback(errors
[
https://issues.apache.org/jira/browse/KAFKA-17572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884066#comment-17884066
]
Chia-Chuan Yu commented on KAFKA-17572:
---
Hi, [~davidarthur]
Can I have this one p
cmccabe opened a new pull request, #17258:
URL: https://github.com/apache/kafka/pull/17258
Several Kafka log configurations in have synonyms. For example, log
retention can be configured either by log.retention.ms, or by
log.retention.minutes, or by log.retention.hours. There is also a facu
junrao commented on code in PR #16443:
URL: https://github.com/apache/kafka/pull/16443#discussion_r1772320884
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -2305,11 +2307,34 @@ public CompletableFuture
updateFeatures(
}).thenApply(r
[
https://issues.apache.org/jira/browse/KAFKA-17584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-17584:
-
Summary: Fix incorrect synonym handling for dynamic log configurations
(was: Incorrect synonym
[
https://issues.apache.org/jira/browse/KAFKA-17584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-17584:
-
Summary: Incorrect synonym handling for dynamic log configurations (was:
Changing dynamic confi
junrao commented on code in PR #17193:
URL: https://github.com/apache/kafka/pull/17193#discussion_r1772299474
##
core/src/main/scala/kafka/log/LogCleaner.scala:
##
@@ -623,8 +623,12 @@ private[log] class Cleaner(val id: Int,
val groupedSegments = groupSegmentsBySize(log.l
jolshan commented on code in PR #16443:
URL: https://github.com/apache/kafka/pull/16443#discussion_r1772275727
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -3603,13 +3603,16 @@ class KafkaApis(val requestChannel: RequestChannel,
def sendResponseCallback(errors
jolshan commented on code in PR #16443:
URL: https://github.com/apache/kafka/pull/16443#discussion_r1772273649
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -3603,13 +3603,16 @@ class KafkaApis(val requestChannel: RequestChannel,
def sendResponseCallback(errors
jolshan commented on code in PR #16443:
URL: https://github.com/apache/kafka/pull/16443#discussion_r1772272543
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -2305,11 +2307,34 @@ public CompletableFuture
updateFeatures(
}).thenApply(
jolshan commented on code in PR #16443:
URL: https://github.com/apache/kafka/pull/16443#discussion_r1772266396
##
metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java:
##
@@ -174,15 +175,27 @@ ControllerResult> updateFeatures(
Map upgradeTypes,
junrao commented on code in PR #16443:
URL: https://github.com/apache/kafka/pull/16443#discussion_r1771950807
##
metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java:
##
@@ -241,6 +255,16 @@ private ApiError updateFeature(
// Perform additio
lianetm opened a new pull request, #17257:
URL: https://github.com/apache/kafka/pull/17257
This PR includes:
- Bump ConsumerGroupHeartbeatRequest version to include subscribedTopicRegex
field
- Introduce new error code for InvalidSubscriptionRegex
- Bump ConsumerGroupHeartbeatRespo
lianetm commented on code in PR #17165:
URL: https://github.com/apache/kafka/pull/17165#discussion_r1772011078
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java:
##
@@ -246,7 +252,9 @@ private void process(final Subscripti
[
https://issues.apache.org/jira/browse/KAFKA-16820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884014#comment-17884014
]
Arushi Helms commented on KAFKA-16820:
--
Hi [~soarez] [~jlprat]
Circling back on th
[
https://issues.apache.org/jira/browse/KAFKA-17587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883993#comment-17883993
]
David Arthur commented on KAFKA-17587:
--
I started splitting out my prototype branch
jsancio commented on PR #17235:
URL: https://github.com/apache/kafka/pull/17235#issuecomment-2369061152
> > I couldn't find anything wrong with that line. Did you mean to link to
another line? Or did I miss something?
>
> `true` -> `true`
Thanks @chia7712 . Done.
--
This is
chia7712 commented on PR #17235:
URL: https://github.com/apache/kafka/pull/17235#issuecomment-2369050800
> I couldn't find anything wrong with that line. Did you mean to link to
another line? Or did I miss something?
`true` -> `true`
--
This is an automated message from the Apache
m1a2st commented on PR #17256:
URL: https://github.com/apache/kafka/pull/17256#issuecomment-2369047651
fix 3.8 version document in this
[PR](https://github.com/apache/kafka-site/pull/632)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
jolshan commented on code in PR #16443:
URL: https://github.com/apache/kafka/pull/16443#discussion_r1771887394
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -2305,11 +2306,23 @@ public CompletableFuture
updateFeatures(
}).thenApply(
m1a2st opened a new pull request, #17256:
URL: https://github.com/apache/kafka/pull/17256
As title, there should be a space between `in` and `kafka.metrics.reporters`
words.
method of the sink connector's has t
jsancio commented on PR #17235:
URL: https://github.com/apache/kafka/pull/17235#issuecomment-2368903179
Thanks @chia7712 . I fixed those encoding issues.
> https://github.com/apache/kafka/blob/trunk/docs/ops.html#L4249
I couldn't find anything wrong with that line. Did you mean to l
lianetm commented on code in PR #17244:
URL: https://github.com/apache/kafka/pull/17244#discussion_r1771804938
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1471,6 +1487,7 @@ public void unsubscribe() {
fetchBuf
[
https://issues.apache.org/jira/browse/KAFKA-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
黃竣陽 resolved KAFKA-17471.
-
Resolution: Won't Fix
> Speed Up ResetConsumerGroupOffsetTest
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883961#comment-17883961
]
黃竣陽 commented on KAFKA-17471:
-
This issue is resolved by https://issues.apache.org/jira/brow
lianetm commented on code in PR #17244:
URL: https://github.com/apache/kafka/pull/17244#discussion_r1771804938
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1471,6 +1487,7 @@ public void unsubscribe() {
fetchBuf
m1a2st commented on PR #16381:
URL: https://github.com/apache/kafka/pull/16381#issuecomment-2368834415
rebase on the trunk, and fix the conflict
--
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 th
Pritam Kumar created KAFKA-17599:
Summary: Update Consumer Subscription with Current Assignment
Before Partition Revocation
Key: KAFKA-17599
URL: https://issues.apache.org/jira/browse/KAFKA-17599
Proj
[
https://issues.apache.org/jira/browse/KAFKA-17590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883955#comment-17883955
]
Jun Rao commented on KAFKA-17590:
-
If the on disk data in fine, this might be a network
dimitarndimitrov commented on code in PR #17221:
URL: https://github.com/apache/kafka/pull/17221#discussion_r1771776869
##
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/HdrHistogramTest.java:
##
@@ -172,4 +177,39 @@ public void testHistogramDataRes
fonsdant commented on PR #17204:
URL: https://github.com/apache/kafka/pull/17204#issuecomment-2368771036
@mumrah, thanks for the explanation. I really appreciate it! :)
I will proceed modifying the script to use ref.
--
This is an automated message from the Apache Git Service.
To re
rreddy-22 commented on code in PR #17093:
URL: https://github.com/apache/kafka/pull/17093#discussion_r1771746899
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -260,6 +325,21 @@ object StorageTool extends Logging {
s"${MetadataVersion.IBP_3_0_IV0}; the defa
fonsdant commented on PR #17198:
URL: https://github.com/apache/kafka/pull/17198#issuecomment-2368758343
I have removed the references to `transform` from docs. I am wondering if it
would be better to replace `transform` with `process`, instead of removing it.
I have started to think about
[
https://issues.apache.org/jira/browse/KAFKA-17572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883942#comment-17883942
]
Chia-Ping Tsai commented on KAFKA-17572:
{quote}
Maybe we can add a conditional
dajac commented on PR #17233:
URL: https://github.com/apache/kafka/pull/17233#issuecomment-2368724037
@FrankYang0529 There are a few conflicts. Could you please address them?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/KAFKA-17572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883931#comment-17883931
]
David Arthur commented on KAFKA-17572:
--
Yes, setting the status to pending seems li
[
https://issues.apache.org/jira/browse/KAFKA-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883917#comment-17883917
]
PoAn Yang commented on KAFKA-17598:
---
Hi [~lianetm], I'm interested in this Jira. Could
frankvicky commented on code in PR #17250:
URL: https://github.com/apache/kafka/pull/17250#discussion_r1771647091
##
tests/kafkatest/tests/core/reassign_partitions_test.py:
##
@@ -176,7 +176,10 @@ def test_reassign_partitions(self, bounce_brokers,
reassign_from_offset_zero, me
chia7712 commented on code in PR #17250:
URL: https://github.com/apache/kafka/pull/17250#discussion_r1771641828
##
tests/kafkatest/tests/core/reassign_partitions_test.py:
##
@@ -176,7 +176,10 @@ def test_reassign_partitions(self, bounce_brokers,
reassign_from_offset_zero, me
m1a2st opened a new pull request, #17254:
URL: https://github.com/apache/kafka/pull/17254
In this test, I think is the
[max.block.ms](https://kafka.apache.org/documentation/#producerconfigs_max.block.ms)
is so short for `initTransactions()`, however this test should test that
commit fail,
[
https://issues.apache.org/jira/browse/KAFKA-17591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-17591:
---
Labels: kip-848 (was: )
> Consumer protocol subscription regex support
> -
Lianet Magrans created KAFKA-17598:
--
Summary: Command line validation tool for RE2J regex
Key: KAFKA-17598
URL: https://issues.apache.org/jira/browse/KAFKA-17598
Project: Kafka
Issue Type: S
Lianet Magrans created KAFKA-17597:
--
Summary: Update OffsetsMetadataManager to consider topics
subscribed from regex
Key: KAFKA-17597
URL: https://issues.apache.org/jira/browse/KAFKA-17597
Project: K
[
https://issues.apache.org/jira/browse/KAFKA-17495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-17495.
-
Fix Version/s: 4.0.0
Resolution: Fixed
> Factor out common setup from server-side assigno
dajac merged PR #17133:
URL: https://github.com/apache/kafka/pull/17133
--
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
mumrah commented on PR #17204:
URL: https://github.com/apache/kafka/pull/17204#issuecomment-2368526553
@fonsdant, just updating the ref on the remote (GitHub) would indeed work.
In Git, a ref is simply a text file with a SHA in it. Conventionally, tags
are immutable since they are typ
Lianet Magrans created KAFKA-17596:
--
Summary: Benchmark regex resolution
Key: KAFKA-17596
URL: https://issues.apache.org/jira/browse/KAFKA-17596
Project: Kafka
Issue Type: Sub-task
Lianet Magrans created KAFKA-17595:
--
Summary: Stored regexes refresh to reflect metadata changes
Key: KAFKA-17595
URL: https://issues.apache.org/jira/browse/KAFKA-17595
Project: Kafka
Issue
Lianet Magrans created KAFKA-17594:
--
Summary: Integrate resolved regexes in assignment computation
Key: KAFKA-17594
URL: https://issues.apache.org/jira/browse/KAFKA-17594
Project: Kafka
Issu
Lianet Magrans created KAFKA-17593:
--
Summary: Async regex resolution
Key: KAFKA-17593
URL: https://issues.apache.org/jira/browse/KAFKA-17593
Project: Kafka
Issue Type: Sub-task
R
Lianet Magrans created KAFKA-17592:
--
Summary: Support for subscription regex in HB RPC
Key: KAFKA-17592
URL: https://issues.apache.org/jira/browse/KAFKA-17592
Project: Kafka
Issue Type: Sub-
Lianet Magrans created KAFKA-17591:
--
Summary: Consumer protocol subscription regex support
Key: KAFKA-17591
URL: https://issues.apache.org/jira/browse/KAFKA-17591
Project: Kafka
Issue Type:
srdo commented on code in PR #17225:
URL: https://github.com/apache/kafka/pull/17225#discussion_r1771535619
##
core/src/test/java/kafka/testkit/KafkaClusterTestKitTest.java:
##
@@ -122,4 +126,25 @@ public void
testCreateClusterAndCloseWithMultipleLogDirs(boolean combined) {
chia7712 commented on code in PR #17225:
URL: https://github.com/apache/kafka/pull/17225#discussion_r1771528836
##
core/src/test/java/kafka/testkit/KafkaClusterTestKitTest.java:
##
@@ -122,4 +126,25 @@ public void
testCreateClusterAndCloseWithMultipleLogDirs(boolean combined) {
srdo commented on code in PR #17225:
URL: https://github.com/apache/kafka/pull/17225#discussion_r1771522261
##
core/src/test/java/kafka/testkit/KafkaClusterTestKitTest.java:
##
@@ -122,4 +126,25 @@ public void
testCreateClusterAndCloseWithMultipleLogDirs(boolean combined) {
olegbonar commented on PR #17253:
URL: https://github.com/apache/kafka/pull/17253#issuecomment-2368206551
@jlprat done
--
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 un
FrankYang0529 commented on code in PR #17244:
URL: https://github.com/apache/kafka/pull/17244#discussion_r1771374443
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1471,6 +1487,7 @@ public void unsubscribe() {
fe
[
https://issues.apache.org/jira/browse/KAFKA-17590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883876#comment-17883876
]
ChenLin commented on KAFKA-17590:
-
hi [~junrao] hi [~ijuma],
could you please have a l
xijiu commented on PR #17231:
URL: https://github.com/apache/kafka/pull/17231#issuecomment-2368132282
@chia7712I have modified the code and remove some getter methods from
`KafkaConfig`,PTAL
--
This is an automated message from the Apache Git Service.
To respond to the message, p
1 - 100 of 139 matches
Mail list logo
