nizhikov commented on PR #15501:
URL: https://github.com/apache/kafka/pull/15501#issuecomment-2126366162
@OmniaGM Are you still working on moving KafkaConfig out of core?
Can you, please, show me PR's you are currently working on regarding
KafkaConfig?
--
This is an automated message
KrishVora01 commented on code in PR #16027:
URL: https://github.com/apache/kafka/pull/16027#discussion_r1611093413
##
docker/generate_kafka_pr_template.py:
##
@@ -0,0 +1,100 @@
+#!/usr/bin/env python
+
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# cont
KrishVora01 commented on code in PR #16027:
URL: https://github.com/apache/kafka/pull/16027#discussion_r1611093207
##
docker/docker_official_image_build_test.py:
##
@@ -0,0 +1,90 @@
+#!/usr/bin/env python
+
+# Licensed to the Apache Software Foundation (ASF) under one or more
+#
KrishVora01 commented on code in PR #16027:
URL: https://github.com/apache/kafka/pull/16027#discussion_r1611092562
##
.github/workflows/prepare_docker_official_image_source.yml:
##
@@ -0,0 +1,53 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contribu
KrishVora01 commented on code in PR #16027:
URL: https://github.com/apache/kafka/pull/16027#discussion_r1611091209
##
.github/workflows/docker_official_image_build_and_test.yml:
##
@@ -0,0 +1,66 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contribu
TaiJuWu commented on code in PR #15862:
URL: https://github.com/apache/kafka/pull/15862#discussion_r1611087227
##
core/src/test/java/kafka/test/junit/ClusterTestExtensionsUnitTest.java:
##
@@ -33,16 +31,22 @@ public class ClusterTestExtensionsUnitTest {
void testProcessClus
VedarthConfluent commented on code in PR #16027:
URL: https://github.com/apache/kafka/pull/16027#discussion_r1611077695
##
docker/generate_kafka_pr_template.py:
##
@@ -0,0 +1,100 @@
+#!/usr/bin/env python
+
+# Licensed to the Apache Software Foundation (ASF) under one or more
+#
showuon commented on code in PR #15825:
URL: https://github.com/apache/kafka/pull/15825#discussion_r1611046740
##
core/src/test/scala/unit/kafka/log/LogSegmentTest.scala:
##
@@ -144,6 +144,35 @@ class LogSegmentTest {
checkEquals(ms2.records.iterator, read.records.records.i
[
https://issues.apache.org/jira/browse/KAFKA-16793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-16793.
-
Fix Version/s: 3.8.0
Reviewer: David Jacot
Resolution: Fixed
> Heartbeat API for
dajac merged PR #15988:
URL: https://github.com/apache/kafka/pull/15988
--
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
dajac commented on PR #15988:
URL: https://github.com/apache/kafka/pull/15988#issuecomment-2126326606
All the
`org.apache.kafka.streams.processor.internals.assignment.RackAwareTaskAssignorTest`
related failures are due to https://github.com/apache/kafka/pull/15972. I will
merge it.
--
T
dajac merged PR #15987:
URL: https://github.com/apache/kafka/pull/15987
--
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
mooner created KAFKA-16825:
--
Summary: CVE vulnerabilities in Jetty and netty
Key: KAFKA-16825
URL: https://issues.apache.org/jira/browse/KAFKA-16825
Project: Kafka
Issue Type: Task
Affects Versi
dajac commented on PR #15972:
URL: https://github.com/apache/kafka/pull/15972#issuecomment-2126312436
Hey @ableegoldman @apourchet, I see new failures in trunk that seems to be
related to this PR. The last build of this PR had 100+ failures:
https://ci-builds.apache.org/blue/organizations/j
VedarthConfluent commented on code in PR #16027:
URL: https://github.com/apache/kafka/pull/16027#discussion_r1611056103
##
docker/docker_official_images/.gitignore:
##
Review Comment:
Can consider using .gitkeep if empty folder is needed
--
This is an automated message
VedarthConfluent commented on code in PR #16027:
URL: https://github.com/apache/kafka/pull/16027#discussion_r1611048213
##
docker/docker_official_images/.gitignore:
##
Review Comment:
Not needed, we can remove this
--
This is an automated message from the Apache Git Ser
VedarthConfluent commented on code in PR #16027:
URL: https://github.com/apache/kafka/pull/16027#discussion_r1611047289
##
docker/docker_official_image_build_test.py:
##
@@ -0,0 +1,90 @@
+#!/usr/bin/env python
+
+# Licensed to the Apache Software Foundation (ASF) under one or mo
VedarthConfluent commented on code in PR #16027:
URL: https://github.com/apache/kafka/pull/16027#discussion_r1611042138
##
.github/workflows/prepare_docker_official_image_source.yml:
##
@@ -0,0 +1,53 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# con
VedarthConfluent commented on code in PR #16027:
URL: https://github.com/apache/kafka/pull/16027#discussion_r1611041547
##
.github/workflows/prepare_docker_official_image_source.yml:
##
@@ -0,0 +1,53 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# con
VedarthConfluent commented on code in PR #16027:
URL: https://github.com/apache/kafka/pull/16027#discussion_r1611040507
##
.github/workflows/docker_official_image_build_and_test.yml:
##
@@ -0,0 +1,66 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# con
[
https://issues.apache.org/jira/browse/KAFKA-16257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Yang reassigned KAFKA-16257:
Assignee: Fan Yang
> SchemaProjector should be extensible to logical types
>
[
https://issues.apache.org/jira/browse/KAFKA-16820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848821#comment-17848821
]
Vikash Mishra commented on KAFKA-16820:
---
Despite the fact that brokers are provide
fanyang opened a new pull request, #16035:
URL: https://github.com/apache/kafka/pull/16035
This PR improved logical type compatibility in SchemaProjector.
Decimal type with higher scale is compatible with one with same or lower
scale.
Timestamp type is compatible with Date and Time typ
mjsax merged PR #16028:
URL: https://github.com/apache/kafka/pull/16028
--
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 #16028:
URL: https://github.com/apache/kafka/pull/16028#discussion_r1610944460
##
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java:
##
@@ -149,6 +149,14 @@ private StateStoreMetrics() {}
private stat
github-actions[bot] commented on PR #15264:
URL: https://github.com/apache/kafka/pull/15264#issuecomment-2126168320
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 ask a committer for
review. If the PR has merge
kamalcph commented on code in PR #15825:
URL: https://github.com/apache/kafka/pull/15825#discussion_r1610893769
##
core/src/test/scala/integration/kafka/server/DelayedFetchTest.scala:
##
@@ -164,18 +169,71 @@ class DelayedFetchTest {
assertTrue(delayedFetch.tryComplete())
kamalcph commented on code in PR #15825:
URL: https://github.com/apache/kafka/pull/15825#discussion_r1610893769
##
core/src/test/scala/integration/kafka/server/DelayedFetchTest.scala:
##
@@ -164,18 +169,71 @@ class DelayedFetchTest {
assertTrue(delayedFetch.tryComplete())
[
https://issues.apache.org/jira/browse/KAFKA-16811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848797#comment-17848797
]
Rohan Desai commented on KAFKA-16811:
-
Alternatively, or perhaps in addition to a pr
kamalcph commented on code in PR #15825:
URL: https://github.com/apache/kafka/pull/15825#discussion_r1610895466
##
core/src/main/scala/kafka/server/DelayedFetch.scala:
##
@@ -91,19 +91,23 @@ class DelayedFetch(
// Go directly to the check for Case G if the message o
kamalcph commented on code in PR #15825:
URL: https://github.com/apache/kafka/pull/15825#discussion_r1610893769
##
core/src/test/scala/integration/kafka/server/DelayedFetchTest.scala:
##
@@ -164,18 +169,71 @@ class DelayedFetchTest {
assertTrue(delayedFetch.tryComplete())
[
https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848791#comment-17848791
]
Phuc Hong Tran commented on KAFKA-16160:
[~pnee] I understand
> AsyncKafkaCons
[
https://issues.apache.org/jira/browse/KAFKA-14517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848792#comment-17848792
]
Phuc Hong Tran commented on KAFKA-14517:
Thanks again [~lianetm]
> Implement r
gongxuanzhang commented on code in PR #16010:
URL: https://github.com/apache/kafka/pull/16010#discussion_r1610875448
##
core/src/test/scala/unit/kafka/tools/StorageToolTest.scala:
##
@@ -488,4 +488,26 @@ Found problem:
assertEquals(1, exitStatus)
}
}
+
+ @Test
+
mjsax commented on PR #15975:
URL: https://github.com/apache/kafka/pull/15975#issuecomment-2126049466
Makes sense. Could you file a Jira for the KIP and the follow up cleanup for
KS code to use it :)
--
This is an automated message from the Apache Git Service.
To respond to the message,
showuon commented on code in PR #15951:
URL: https://github.com/apache/kafka/pull/15951#discussion_r1610854305
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -2114,16 +2114,12 @@ class ReplicaManager(val config: KafkaConfig,
partition.log.foreach { _ =>
andreyolv commented on PR #2873:
URL: https://github.com/apache/kafka/pull/2873#issuecomment-2125996595
Extremely important feature for governance. Any release forecast?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
apourchet commented on code in PR #16034:
URL: https://github.com/apache/kafka/pull/16034#discussion_r1610816330
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java:
##
@@ -513,50 +515,45 @@ private ApplicationState buildApplicatio
m1a2st commented on code in PR #15779:
URL: https://github.com/apache/kafka/pull/15779#discussion_r1610809626
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/ResetConsumerGroupOffsetTest.java:
##
@@ -62,506 +86,756 @@
* - scope=topics+partitions, scenario=to-earli
[
https://issues.apache.org/jira/browse/KAFKA-16814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848781#comment-17848781
]
Luke Chen commented on KAFKA-16814:
---
[~muralibasani] , no, it's not related to remote
gharris1727 commented on code in PR #16001:
URL: https://github.com/apache/kafka/pull/16001#discussion_r1610727814
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java:
##
@@ -1039,7 +1039,12 @@ public static List>
reverseTransform(String connNa
appchemist commented on PR #15961:
URL: https://github.com/apache/kafka/pull/15961#issuecomment-2125950049
@lianetm I got it, Thank you!
@kirktrue Right! I think what you said is simple and more intuitive.
--
This is an automated message from the Apache Git Service.
To respond to the me
[
https://issues.apache.org/jira/browse/KAFKA-15630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris updated KAFKA-15630:
Labels: newbie (was: )
> Improve documentation of offset.lag.max
> --
[
https://issues.apache.org/jira/browse/KAFKA-15630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris updated KAFKA-15630:
Description:
It would be good to expand on the role of this configuration on offset
translation a
[
https://issues.apache.org/jira/browse/KAFKA-16798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848770#comment-17848770
]
Greg Harris commented on KAFKA-16798:
-
Hi [~sektor.coder] There's already a ticket t
ableegoldman commented on code in PR #16034:
URL: https://github.com/apache/kafka/pull/16034#discussion_r1610769106
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackUtils.java:
##
@@ -38,26 +40,37 @@ public final class RackUtils {
priva
apourchet commented on code in PR #16033:
URL: https://github.com/apache/kafka/pull/16033#discussion_r1610768911
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java:
##
@@ -486,12 +486,12 @@ public long optimizeStandbyTasks
apourchet commented on code in PR #16033:
URL: https://github.com/apache/kafka/pull/16033#discussion_r1610767256
##
streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskInfo.java:
##
@@ -50,6 +50,12 @@ public interface TaskInfo {
*/
Set stateStoreNa
ableegoldman merged PR #16024:
URL: https://github.com/apache/kafka/pull/16024
--
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.ap
apourchet opened a new pull request, #16034:
URL: https://github.com/apache/kafka/pull/16034
This PR uses the new TaskTopicPartition structure to simplify the build
process for the ApplicationState, which is the input to the new
TaskAssignor#assign call.
--
This is an automated messa
[
https://issues.apache.org/jira/browse/KAFKA-16798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848767#comment-17848767
]
Thanos Athanasopoulos edited comment on KAFKA-16798 at 5/22/24 10:44 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-16798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848767#comment-17848767
]
Thanos Athanasopoulos edited comment on KAFKA-16798 at 5/22/24 10:39 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-16798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848767#comment-17848767
]
Thanos Athanasopoulos edited comment on KAFKA-16798 at 5/22/24 10:38 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-16798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848767#comment-17848767
]
Thanos Athanasopoulos commented on KAFKA-16798:
---
[~gharris1727] that was t
dongnuo123 commented on code in PR #15988:
URL: https://github.com/apache/kafka/pull/15988#discussion_r1610735381
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -12401,6 +12436,363 @@ public void
testClassicGroupSyncTo
[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-15284:
-
Assignee: (was: Kirk True)
> Implement ConsumerGroupProtocolVersionResolver to determine co
dongnuo123 commented on code in PR #15988:
URL: https://github.com/apache/kafka/pull/15988#discussion_r1610729396
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -12143,7 +12183,6 @@ public void
testClassicGroupSyncToCo
dongnuo123 commented on code in PR #15988:
URL: https://github.com/apache/kafka/pull/15988#discussion_r1610728790
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -4274,6 +4343,81 @@ private void validateClassicGroupHeartbeat
C0urante commented on code in PR #16001:
URL: https://github.com/apache/kafka/pull/16001#discussion_r1610679966
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConfigHash.java:
##
@@ -0,0 +1,245 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
C0urante commented on PR #16001:
URL: https://github.com/apache/kafka/pull/16001#issuecomment-2125789945
After some offline discussion with @gharris1727 we realized there was a
potential for infinite rebalance loops with the previous implementation when
config providers resolved values diff
[
https://issues.apache.org/jira/browse/KAFKA-16815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans reassigned KAFKA-16815:
--
Assignee: Lianet Magrans
> Handle FencedInstanceId on heartbeat for new consumer
> --
[
https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-16160.
Resolution: Cannot Reproduce
> AsyncKafkaConsumer is trying to connect to a disconnected node in a
[
https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848748#comment-17848748
]
Philip Nee commented on KAFKA-16160:
Hey [~phuctran] - I'm going to close this issue
[
https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jon Chiu updated KAFKA-16160:
-
Priority: Major (was: Blocker)
> AsyncKafkaConsumer is trying to connect to a disconnected node in a ti
[
https://issues.apache.org/jira/browse/KAFKA-16623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jon Chiu reassigned KAFKA-16623:
Assignee: Lianet Magrans (was: Kirk True)
> KafkaAsyncConsumer system tests warn about revoking
emitskevich-blp commented on code in PR #15889:
URL: https://github.com/apache/kafka/pull/15889#discussion_r1610656953
##
clients/src/main/java/org/apache/kafka/common/metrics/stats/SampledStat.java:
##
@@ -50,10 +50,13 @@ public void record(MetricConfig config, double value, lo
emitskevich-blp commented on code in PR #15889:
URL: https://github.com/apache/kafka/pull/15889#discussion_r1610656953
##
clients/src/main/java/org/apache/kafka/common/metrics/stats/SampledStat.java:
##
@@ -50,10 +50,13 @@ public void record(MetricConfig config, double value, lo
[
https://issues.apache.org/jira/browse/KAFKA-16639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16639:
--
Priority: Critical (was: Major)
> AsyncKafkaConsumer#close does not send heartbeat to leave group
> -
emitskevich-blp commented on code in PR #15889:
URL: https://github.com/apache/kafka/pull/15889#discussion_r1610653813
##
clients/src/test/java/org/apache/kafka/common/metrics/stats/SampledStatTest.java:
##
@@ -0,0 +1,110 @@
+/*
+ * Licensed to the Apache Software Foundation (AS
apourchet opened a new pull request, #16033:
URL: https://github.com/apache/kafka/pull/16033
This PR implements the rack aware optimization of active tasks that can be
used by the assignors themselves. It takes in the full output of the assignment
and tries to reorganize it so as to minimiz
jsancio commented on code in PR #15986:
URL: https://github.com/apache/kafka/pull/15986#discussion_r1610641974
##
core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala:
##
@@ -1366,6 +1368,26 @@ class KafkaConfigTest {
assertEquals(expectedVoters, addresses)
}
+
José Armando García Sancio created KAFKA-16824:
--
Summary: Utils.getHost and Utils.getPort do not catch a lot of
invalid host and ports
Key: KAFKA-16824
URL: https://issues.apache.org/jira/browse/KAFKA
lianetm opened a new pull request, #16032:
URL: https://github.com/apache/kafka/pull/16032
KafkaConsumerTest contained lots of unit tests that were not enabled for the
new consumer, with TODOs for verifying if they cold be enabled. This PR enables
all the unit tests that could be applied/pa
gharris1727 commented on code in PR #13277:
URL: https://github.com/apache/kafka/pull/13277#discussion_r1610617003
##
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java:
##
@@ -219,6 +219,19 @@ public class CommonClientConfigs {
public static final Stri
Lianet Magrans created KAFKA-16823:
--
Summary: Extract LegacyConsumer-specific unit tests from generic
KafkaConsumerTest
Key: KAFKA-16823
URL: https://issues.apache.org/jira/browse/KAFKA-16823
Projec
jolshan commented on code in PR #15968:
URL: https://github.com/apache/kafka/pull/15968#discussion_r1610605263
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -1361,10 +1366,10 @@ class ReplicaManager(val config: KafkaConfig,
*/
private def appendToLocalLo
junrao commented on code in PR #15889:
URL: https://github.com/apache/kafka/pull/15889#discussion_r1610602287
##
clients/src/main/java/org/apache/kafka/common/metrics/stats/SampledStat.java:
##
@@ -106,44 +109,51 @@ public String toString() {
public abstract double combin
ableegoldman merged PR #16004:
URL: https://github.com/apache/kafka/pull/16004
--
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.ap
ableegoldman merged PR #15972:
URL: https://github.com/apache/kafka/pull/15972
--
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.ap
[
https://issues.apache.org/jira/browse/KAFKA-16819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16819:
--
Labels: consumer-threading-refactor (was: )
> CoordinatorRequestManager seems to return 0ms during th
[
https://issues.apache.org/jira/browse/KAFKA-16819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16819:
--
Component/s: clients
> CoordinatorRequestManager seems to return 0ms during the coordinator discovery
junrao commented on code in PR #15825:
URL: https://github.com/apache/kafka/pull/15825#discussion_r1610572095
##
core/src/main/scala/kafka/server/DelayedFetch.scala:
##
@@ -91,19 +91,23 @@ class DelayedFetch(
// Go directly to the check for Case G if the message off
chia7712 commented on code in PR #15830:
URL: https://github.com/apache/kafka/pull/15830#discussion_r1610529172
##
core/src/test/scala/unit/kafka/admin/AclCommandTest.scala:
##
@@ -122,19 +128,27 @@ class AclCommandTest extends QuorumTestHarness with
Logging {
super.tearDo
Apoorv Mittal created KAFKA-16822:
-
Summary: Abstract consumer group in coordinator to share
functionality with share group
Key: KAFKA-16822
URL: https://issues.apache.org/jira/browse/KAFKA-16822
Proj
[
https://issues.apache.org/jira/browse/KAFKA-16766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16766:
---
Description:
If a call to consumer.offsetsForTimes times out, the new AsyncKafkaConsumer
wi
chia7712 commented on code in PR #15889:
URL: https://github.com/apache/kafka/pull/15889#discussion_r1610336329
##
clients/src/main/java/org/apache/kafka/common/metrics/stats/SampledStat.java:
##
@@ -40,7 +40,7 @@ public abstract class SampledStat implements MeasurableStat {
jolshan commented on code in PR #15685:
URL: https://github.com/apache/kafka/pull/15685#discussion_r1610507371
##
server-common/src/main/java/org/apache/kafka/server/common/TestFeatureVersion.java:
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
Ritika Reddy created KAFKA-16821:
Summary: Create a new interface to store member metadata
Key: KAFKA-16821
URL: https://issues.apache.org/jira/browse/KAFKA-16821
Project: Kafka
Issue Type: S
jeffkbkim commented on code in PR #15988:
URL: https://github.com/apache/kafka/pull/15988#discussion_r1610481770
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -12401,6 +12436,363 @@ public void
testClassicGroupSyncToC
jolshan commented on code in PR #15685:
URL: https://github.com/apache/kafka/pull/15685#discussion_r1610472137
##
server-common/src/main/java/org/apache/kafka/server/common/Features.java:
##
@@ -64,14 +63,16 @@ public enum Features {
PRODUCTION_FEATURES = Arrays.strea
jolshan commented on code in PR #15685:
URL: https://github.com/apache/kafka/pull/15685#discussion_r1610471028
##
server-common/src/main/java/org/apache/kafka/server/common/FeatureVersion.java:
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under on
jolshan commented on code in PR #15685:
URL: https://github.com/apache/kafka/pull/15685#discussion_r1610471028
##
server-common/src/main/java/org/apache/kafka/server/common/FeatureVersion.java:
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under on
jeffkbkim commented on code in PR #15988:
URL: https://github.com/apache/kafka/pull/15988#discussion_r1610471371
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -12401,6 +12436,363 @@ public void
testClassicGroupSyncToC
[
https://issues.apache.org/jira/browse/KAFKA-16820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arushi Helms updated KAFKA-16820:
-
Description:
We are migrating our Kafka cluster from zookeeper to Kraft mode. We are running
muralibasani commented on PR #16005:
URL: https://github.com/apache/kafka/pull/16005#issuecomment-2125492819
@nikramakrishnan
I think calling applyDelta on replicaManager wouldn't invoke configure on
rlmm. Probably we should start mocking from BrokerServer.startup method, and
create a t
jsancio commented on code in PR #16008:
URL: https://github.com/apache/kafka/pull/16008#discussion_r1610457959
##
core/src/main/scala/kafka/server/NodeToControllerChannelManager.scala:
##
@@ -120,15 +118,15 @@ object RaftControllerNodeProvider {
*/
class RaftControllerNodePro
[
https://issues.apache.org/jira/browse/KAFKA-16820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arushi Helms updated KAFKA-16820:
-
Description:
We are migrating our Kafka cluster from zookeeper to Kraft mode. We are running
Arushi Helms created KAFKA-16820:
Summary: Kafka Broker fails to connect to Kraft Controller with no
DNS matching
Key: KAFKA-16820
URL: https://issues.apache.org/jira/browse/KAFKA-16820
Project: Kafk
jeffkbkim commented on code in PR #15988:
URL: https://github.com/apache/kafka/pull/15988#discussion_r1610462585
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -12401,6 +12436,363 @@ public void
testClassicGroupSyncToC
jeffkbkim commented on code in PR #15988:
URL: https://github.com/apache/kafka/pull/15988#discussion_r1610460306
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -12401,6 +12436,363 @@ public void
testClassicGroupSyncToC
1 - 100 of 233 matches
Mail list logo
