hudeqi commented on PR #14622:
URL: https://github.com/apache/kafka/pull/14622#issuecomment-1778633171
@divijvaidya This flaky test caused by Files.walk would occasionally fail
when I ran it locally repeatedly. After modifying this PR, the local repeated
execution has become normal in my lo
hudeqi closed pull request #14622: KAFKA-15671:Fix NoSuchFileException from
Files.walk
URL: https://github.com/apache/kafka/pull/14622
--
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 co
hudeqi commented on PR #14553:
URL: https://github.com/apache/kafka/pull/14553#issuecomment-1778612496
> > I tested this process on the latest trunk branch and it did not
reproduce. My process is: create a topic with 1 partition, then write traffic
and stop writing. For example, the current
drawxy commented on code in PR #14553:
URL: https://github.com/apache/kafka/pull/14553#discussion_r1371202846
##
core/src/main/scala/kafka/log/LogManager.scala:
##
@@ -1156,6 +1156,9 @@ class LogManager(logDirs: Seq[File],
// we will add metrics back after sourceLog remov
drawxy commented on PR #14553:
URL: https://github.com/apache/kafka/pull/14553#issuecomment-1778571795
> I tested this process on the latest trunk branch and it did not reproduce.
My process is: create a topic with 1 partition, then write traffic and stop
writing. For example, the current i
drawxy closed pull request #14553: KAFKA-15608: Assign lastet leader eopch and
offset checkpoint to future log when replacing current log
URL: https://github.com/apache/kafka/pull/14553
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
drawxy commented on PR #14553:
URL: https://github.com/apache/kafka/pull/14553#issuecomment-1778559531
> I tested this process on the latest trunk branch and it did not reproduce.
My process is: create a topic with 1 partition, then write traffic and stop
writing. For example, the current i
kumarpritam863 opened a new pull request, #14630:
URL: https://github.com/apache/kafka/pull/14630
* In ICR(Incremental Cooperative Rebalancing) mode, whenever a new worker,
say Worker 3 joins, a new global assignment is computed by the leader, say
Worker1, that results in the revocation of
Pritam Kumar created KAFKA-15680:
Summary: Partition-Count is not getting updated Correctly in the
Incremental Co-operative Rebalancing(ICR) Mode of Rebalancing
Key: KAFKA-15680
URL: https://issues.apache.org/jira
CalvinConfluent commented on code in PR #14593:
URL: https://github.com/apache/kafka/pull/14593#discussion_r1371143824
##
metadata/src/main/java/org/apache/kafka/controller/PartitionChangeBuilder.java:
##
@@ -361,11 +410,12 @@ public Optional build() {
maybeUpdateReco
CalvinConfluent commented on code in PR #14593:
URL: https://github.com/apache/kafka/pull/14593#discussion_r1371143671
##
metadata/src/main/java/org/apache/kafka/controller/PartitionChangeBuilder.java:
##
@@ -93,6 +93,9 @@ public enum Election {
private boolean eligibleLead
hudeqi commented on PR #14553:
URL: https://github.com/apache/kafka/pull/14553#issuecomment-1778486603
I tested this process on the latest trunk branch and it did not reproduce.
My process is: create a topic with 1 partition, then write traffic and stop
writing. For example, the current isr
hudeqi commented on code in PR #14553:
URL: https://github.com/apache/kafka/pull/14553#discussion_r1371126756
##
core/src/main/scala/kafka/log/LogManager.scala:
##
@@ -1156,6 +1156,9 @@ class LogManager(logDirs: Seq[File],
// we will add metrics back after sourceLog remov
philipnee commented on code in PR #14621:
URL: https://github.com/apache/kafka/pull/14621#discussion_r1371125365
##
core/src/main/scala/kafka/metrics/ClientMetricsConfig.scala:
##
@@ -0,0 +1,141 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * co
philipnee commented on code in PR #14621:
URL: https://github.com/apache/kafka/pull/14621#discussion_r1371110225
##
core/src/main/scala/kafka/metrics/ClientMetricsMetadata.scala:
##
@@ -0,0 +1,130 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
philipnee commented on code in PR #14621:
URL: https://github.com/apache/kafka/pull/14621#discussion_r1371108662
##
core/src/main/scala/kafka/metrics/ClientMetricsMetadata.scala:
##
@@ -0,0 +1,130 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
CalvinConfluent commented on code in PR #14603:
URL: https://github.com/apache/kafka/pull/14603#discussion_r1371113716
##
storage/src/main/java/org/apache/kafka/storage/internals/log/CleanShutdownFileHandler.java:
##
@@ -85,17 +83,16 @@ void write(long brokerEpoch, int version)
CalvinConfluent commented on code in PR #14603:
URL: https://github.com/apache/kafka/pull/14603#discussion_r1371113599
##
storage/src/main/java/org/apache/kafka/storage/internals/log/CleanShutdownFileHandler.java:
##
@@ -85,17 +83,16 @@ void write(long brokerEpoch, int version)
philipnee commented on code in PR #14621:
URL: https://github.com/apache/kafka/pull/14621#discussion_r1371112996
##
core/src/test/scala/kafka/metrics/ClientMetricsTestUtils.scala:
##
@@ -0,0 +1,39 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
philipnee commented on code in PR #14621:
URL: https://github.com/apache/kafka/pull/14621#discussion_r1371110225
##
core/src/main/scala/kafka/metrics/ClientMetricsMetadata.scala:
##
@@ -0,0 +1,130 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
philipnee commented on code in PR #14621:
URL: https://github.com/apache/kafka/pull/14621#discussion_r1371108662
##
core/src/main/scala/kafka/metrics/ClientMetricsMetadata.scala:
##
@@ -0,0 +1,130 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
philipnee commented on code in PR #14621:
URL: https://github.com/apache/kafka/pull/14621#discussion_r1371106132
##
core/src/main/scala/kafka/metrics/ClientMetricsMetadata.scala:
##
@@ -0,0 +1,130 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
github-actions[bot] commented on PR #13417:
URL: https://github.com/apache/kafka/pull/13417#issuecomment-1778451254
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
ijuma commented on code in PR #14603:
URL: https://github.com/apache/kafka/pull/14603#discussion_r1371089424
##
storage/src/main/java/org/apache/kafka/storage/internals/log/CleanShutdownFileHandler.java:
##
@@ -85,17 +83,16 @@ void write(long brokerEpoch, int version) throws Exc
ijuma commented on code in PR #14603:
URL: https://github.com/apache/kafka/pull/14603#discussion_r1371088934
##
storage/src/main/java/org/apache/kafka/storage/internals/log/CleanShutdownFileHandler.java:
##
@@ -85,17 +83,16 @@ void write(long brokerEpoch, int version) throws Exc
CalvinConfluent commented on code in PR #14603:
URL: https://github.com/apache/kafka/pull/14603#discussion_r1371084764
##
storage/src/main/java/org/apache/kafka/storage/internals/log/CleanShutdownFileHandler.java:
##
@@ -85,17 +83,16 @@ void write(long brokerEpoch, int version)
pprovenzano commented on code in PR #14628:
URL: https://github.com/apache/kafka/pull/14628#discussion_r1371083468
##
core/src/test/java/kafka/testkit/KafkaClusterTestKit.java:
##
@@ -227,8 +231,12 @@ public KafkaClusterTestKit build() throws Exception {
set
CalvinConfluent commented on code in PR #14603:
URL: https://github.com/apache/kafka/pull/14603#discussion_r1371084404
##
storage/src/main/java/org/apache/kafka/storage/internals/log/CleanShutdownFileHandler.java:
##
@@ -49,13 +47,15 @@ public class CleanShutdownFileHandler {
CalvinConfluent commented on code in PR #14603:
URL: https://github.com/apache/kafka/pull/14603#discussion_r1371084249
##
storage/src/main/java/org/apache/kafka/storage/internals/log/CleanShutdownFileHandler.java:
##
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-p
dengziming merged PR #14616:
URL: https://github.com/apache/kafka/pull/14616
--
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
rreddy-22 commented on code in PR #14524:
URL: https://github.com/apache/kafka/pull/14524#discussion_r1370533091
##
tests/kafkatest/services/kafka/kafka.py:
##
@@ -277,6 +279,22 @@ def __init__(self, context, num_nodes, zk,
security_protocol=SecurityConfig.PLAI
self.is
rreddy-22 commented on PR #14524:
URL: https://github.com/apache/kafka/pull/14524#issuecomment-1778311241
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/5907/ -
Latest test build
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
[
https://issues.apache.org/jira/browse/KAFKA-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779278#comment-17779278
]
Philip Nee commented on KAFKA-15602:
Hi [~luke.kirby] - Here's the guide to create a
[
https://issues.apache.org/jira/browse/KAFKA-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779276#comment-17779276
]
Luke Kirby commented on KAFKA-15602:
>Well, in example one, the position is at 4, an
[
https://issues.apache.org/jira/browse/KAFKA-15455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yi Ding updated KAFKA-15455:
Labels: kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was:
kip-848 kip-848-client-support k
jolshan commented on code in PR #14629:
URL: https://github.com/apache/kafka/pull/14629#discussion_r1370909940
##
core/src/main/scala/kafka/server/KafkaRequestHandler.scala:
##
@@ -55,23 +55,23 @@ object KafkaRequestHandler {
* @param fun Callback function to execute
* @
jolshan commented on code in PR #14629:
URL: https://github.com/apache/kafka/pull/14629#discussion_r1370909940
##
core/src/main/scala/kafka/server/KafkaRequestHandler.scala:
##
@@ -55,23 +55,23 @@ object KafkaRequestHandler {
* @param fun Callback function to execute
* @
jolshan commented on code in PR #14629:
URL: https://github.com/apache/kafka/pull/14629#discussion_r1370901998
##
core/src/main/scala/kafka/server/KafkaRequestHandler.scala:
##
@@ -55,23 +55,23 @@ object KafkaRequestHandler {
* @param fun Callback function to execute
* @
junrao commented on code in PR #14575:
URL: https://github.com/apache/kafka/pull/14575#discussion_r1370888347
##
clients/src/main/java/org/apache/kafka/common/telemetry/ClientTelemetry.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one o
jolshan commented on code in PR #14629:
URL: https://github.com/apache/kafka/pull/14629#discussion_r1370892267
##
core/src/main/scala/kafka/server/KafkaRequestHandler.scala:
##
@@ -55,23 +55,23 @@ object KafkaRequestHandler {
* @param fun Callback function to execute
* @
jolshan commented on code in PR #14629:
URL: https://github.com/apache/kafka/pull/14629#discussion_r1370892267
##
core/src/main/scala/kafka/server/KafkaRequestHandler.scala:
##
@@ -55,23 +55,23 @@ object KafkaRequestHandler {
* @param fun Callback function to execute
* @
hanyuzheng7 commented on code in PR #14570:
URL: https://github.com/apache/kafka/pull/14570#discussion_r1370877692
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -776,64 +779,55 @@ public void verifyStore() {
g
jolshan opened a new pull request, #14629:
URL: https://github.com/apache/kafka/pull/14629
With the new callback mechanism we were accidentally passing context with
the wrong request local. Now include a RequestLocal as an explicit argument to
the callback.
Also make the arguments p
cmccabe opened a new pull request, #14628:
URL: https://github.com/apache/kafka/pull/14628
(no comment)
--
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-ma
junrao commented on code in PR #14603:
URL: https://github.com/apache/kafka/pull/14603#discussion_r1370850704
##
storage/src/main/java/org/apache/kafka/storage/internals/log/CleanShutdownFileHandler.java:
##
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package ka
artemlivshits commented on code in PR #14593:
URL: https://github.com/apache/kafka/pull/14593#discussion_r1370847603
##
metadata/src/main/java/org/apache/kafka/controller/PartitionChangeBuilder.java:
##
@@ -361,11 +410,12 @@ public Optional build() {
maybeUpdateRecord
AndrewJSchofield commented on code in PR #14621:
URL: https://github.com/apache/kafka/pull/14621#discussion_r1370842597
##
core/src/main/scala/kafka/server/ZkConfigManager.scala:
##
@@ -38,7 +38,8 @@ object ConfigType {
val User = "users"
val Broker = "brokers"
val Ip =
[
https://issues.apache.org/jira/browse/KAFKA-15304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-15304.
---
Fix Version/s: 3.7.0
Reviewer: Jun Rao
Resolution: Fixed
Fixed as part of PR [#14406
chb2ab opened a new pull request, #14627:
URL: https://github.com/apache/kafka/pull/14627
Separating out the protocol changes from
https://github.com/apache/kafka/pull/1 in an effort to more quickly unblock
the client side PR.
https://cwiki.apache.org/confluence/display/KAFKA/KI
[
https://issues.apache.org/jira/browse/KAFKA-15188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15188:
--
Description:
There are several {{Consumer}} APIs that only touch the {{ConsumerMetadata}}
and/or {{Su
[
https://issues.apache.org/jira/browse/KAFKA-15184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779252#comment-17779252
]
Kirk True edited comment on KAFKA-15184 at 10/24/23 9:17 PM:
-
aliehsaeedii opened a new pull request, #14626:
URL: https://github.com/apache/kafka/pull/14626
This is a POC PR for KIP-968.
--
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 comm
[
https://issues.apache.org/jira/browse/KAFKA-15456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15456:
--
Labels: kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was:
kip-848 kip-848-client-suppo
junrao merged PR #14406:
URL: https://github.com/apache/kafka/pull/14406
--
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
[
https://issues.apache.org/jira/browse/KAFKA-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779216#comment-17779216
]
Matthias J. Sax commented on KAFKA-15602:
-
{quote}I'm not entirely sure I unders
kirktrue commented on PR #14406:
URL: https://github.com/apache/kafka/pull/14406#issuecomment-1777892441
@junrao—yes. Here's a brief history for JDK 21, starting with the most
recent build (build 74):
* [build
74](https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-
junrao commented on PR #14406:
URL: https://github.com/apache/kafka/pull/14406#issuecomment-1777855712
@kirktrue : The build for JDK 21 and Scala 2.13 failed this time. Did it
succeed before?
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
[
https://issues.apache.org/jira/browse/KAFKA-15678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-15678:
--
Description:
I am facing an issue on the remote data path for uncommitted reads.
As m
gaurav-narula opened a new pull request, #14625:
URL: https://github.com/apache/kafka/pull/14625
PR #13135 introduced tests in DefaultRecordBatchTest which require filling
buffers with random data. Using
`SecureRandom.getInstanceStrong()` results in using `/dev/random` which is
known to
bbejeck commented on PR #14624:
URL: https://github.com/apache/kafka/pull/14624#issuecomment-1777825636
@mjsax it looks like the build is failing with a checkstyle error though
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
lihaosky commented on code in PR #14624:
URL: https://github.com/apache/kafka/pull/14624#discussion_r1370675126
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java:
##
@@ -264,23 +264,25 @@ private void fetchAndEmit(final Record
CalvinConfluent commented on code in PR #14603:
URL: https://github.com/apache/kafka/pull/14603#discussion_r1370658110
##
storage/src/main/java/org/apache/kafka/storage/internals/util/CleanShutdownFileHandler.java:
##
@@ -85,6 +85,7 @@ void write(long brokerEpoch, int version) t
CalvinConfluent commented on code in PR #14603:
URL: https://github.com/apache/kafka/pull/14603#discussion_r1370657796
##
storage/src/main/java/org/apache/kafka/storage/internals/util/CleanShutdownFileHandler.java:
##
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-
[
https://issues.apache.org/jira/browse/KAFKA-15676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-15676:
--
Description:
When a Connect worker loses contact with the group coordinator, it voluntarily
g
mjsax opened a new pull request, #14624:
URL: https://github.com/apache/kafka/pull/14624
(no comment)
--
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
kirktrue commented on code in PR #14565:
URL: https://github.com/apache/kafka/pull/14565#discussion_r1370618922
##
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java:
##
@@ -976,15 +1053,14 @@ public void subscribe(Collection topics) {
* Group rebal
kirktrue commented on code in PR #14565:
URL: https://github.com/apache/kafka/pull/14565#discussion_r1370615968
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerRebalanceListenerInvoker.java:
##
@@ -0,0 +1,128 @@
+/*
+ * Licensed to the Apache Softwar
[
https://issues.apache.org/jira/browse/KAFKA-15678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-15678:
--
Description:
I am facing an issue on the remote data path for uncommitted reads.
As m
[
https://issues.apache.org/jira/browse/KAFKA-15678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-15678:
--
Description:
I am facing an issue on the remote data path for uncommitted reads.
As m
[
https://issues.apache.org/jira/browse/KAFKA-15679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15679:
---
Summary: Client support for new consumer configs (was: Client support fore
new consumer con
[
https://issues.apache.org/jira/browse/KAFKA-15301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-15301:
--
Description:
I have a use case where tiered storage plugin received requests for activ
msn-tldr commented on code in PR #14564:
URL: https://github.com/apache/kafka/pull/14564#discussion_r1370368421
##
clients/src/main/java/org/apache/kafka/clients/MetadataCache.java:
##
@@ -150,7 +150,7 @@ MetadataCache mergeWith(String newClusterId,
// We want the most
[
https://issues.apache.org/jira/browse/KAFKA-15678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-15678:
--
Description:
I am facing an issue on the remote data path for uncommitted reads.
As m
[
https://issues.apache.org/jira/browse/KAFKA-15678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-15678:
--
Description:
I am facing an issue on the remote data path for uncommitted reads.
As m
[
https://issues.apache.org/jira/browse/KAFKA-15679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15679:
---
Summary: Client support fore new consumer configs (was: Client support new
consumer configs
[
https://issues.apache.org/jira/browse/KAFKA-15678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-15678:
--
Description:
I am facing an issue on the remote data path for uncommitted reads.
As m
[
https://issues.apache.org/jira/browse/KAFKA-15678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-15678:
--
Labels: KIP-405 (was: )
> [Tiered Storage] Stall remote reads with long-spanning tran
[
https://issues.apache.org/jira/browse/KAFKA-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779181#comment-17779181
]
Grigorii Piskunov commented on KAFKA-15562:
---
Hi [~pnee] yes, sure. Please shar
Lianet Magrans created KAFKA-15679:
--
Summary: Client support new consumer configs
Key: KAFKA-15679
URL: https://issues.apache.org/jira/browse/KAFKA-15679
Project: Kafka
Issue Type: Sub-task
Alexandre Dupriez created KAFKA-15678:
-
Summary: [Tiered Storage] Stall remote reads with long-spanning
transactions
Key: KAFKA-15678
URL: https://issues.apache.org/jira/browse/KAFKA-15678
Project
maniekes commented on PR #13321:
URL: https://github.com/apache/kafka/pull/13321#issuecomment-1777659808
@divijvaidya looks like it's stale PR :) shall we merge it or close?
--
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-15600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nicholas Telford updated KAFKA-15600:
-
Summary: KIP-990: Capability to PAUSE Tasks on DeserializationException
(was: KIP-990:
[
https://issues.apache.org/jira/browse/KAFKA-15600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nicholas Telford reassigned KAFKA-15600:
Assignee: Nicholas Telford
> KIP-990: Capability to PAUSE Tasks on Deserializatio
[
https://issues.apache.org/jira/browse/KAFKA-15508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-15508:
---
Priority: Minor (was: Blocker)
> Method always return the same value ApplicationEventProcessor.java
[
https://issues.apache.org/jira/browse/KAFKA-15508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779175#comment-17779175
]
Philip Nee commented on KAFKA-15508:
This is not a blocker right?
> Method always r
vamossagar12 commented on PR #14432:
URL: https://github.com/apache/kafka/pull/14432#issuecomment-1777654947
Thanks @dajac , I have addressed all the comments. Have added a couple of
more questions. Thanks for all the pointers, the changes look cleaner than the
previous iteration (to me atl
vamossagar12 commented on code in PR #14432:
URL: https://github.com/apache/kafka/pull/14432#discussion_r1370542261
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -1908,6 +1909,715 @@ public void testLeavingMemberBumpsG
vamossagar12 commented on code in PR #14432:
URL: https://github.com/apache/kafka/pull/14432#discussion_r1370539621
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroup.java:
##
@@ -285,6 +302,11 @@ public ConsumerGroupMember getOrMaybeCre
vamossagar12 commented on code in PR #14432:
URL: https://github.com/apache/kafka/pull/14432#discussion_r1370538866
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -983,27 +1052,125 @@ private
CoordinatorResult consumerGr
vamossagar12 commented on code in PR #14432:
URL: https://github.com/apache/kafka/pull/14432#discussion_r1370533114
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroup.java:
##
@@ -299,6 +321,9 @@ public void updateMember(ConsumerGroupMem
rreddy-22 commented on code in PR #14524:
URL: https://github.com/apache/kafka/pull/14524#discussion_r1370533091
##
tests/kafkatest/services/kafka/kafka.py:
##
@@ -277,6 +279,22 @@ def __init__(self, context, num_nodes, zk,
security_protocol=SecurityConfig.PLAI
self.is
vamossagar12 commented on code in PR #14432:
URL: https://github.com/apache/kafka/pull/14432#discussion_r1370532536
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -983,27 +1052,125 @@ private
CoordinatorResult consumerGr
vamossagar12 commented on code in PR #14432:
URL: https://github.com/apache/kafka/pull/14432#discussion_r1370531600
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -983,27 +1052,125 @@ private
CoordinatorResult consumerGr
vamossagar12 commented on code in PR #14432:
URL: https://github.com/apache/kafka/pull/14432#discussion_r1370523927
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -983,27 +1052,125 @@ private
CoordinatorResult consumerGr
vamossagar12 commented on code in PR #14432:
URL: https://github.com/apache/kafka/pull/14432#discussion_r1370523697
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -747,6 +798,11 @@ private void throwIfMemberEpochIsInvalid(
philipnee commented on code in PR #14565:
URL: https://github.com/apache/kafka/pull/14565#discussion_r1370505973
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerRebalanceListenerInvoker.java:
##
@@ -0,0 +1,128 @@
+/*
+ * Licensed to the Apache Softwa
[
https://issues.apache.org/jira/browse/KAFKA-15676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-15676:
--
Description:
When a Connect worker loses contact with the group coordinator, it voluntarily
g
philipnee commented on code in PR #14565:
URL: https://github.com/apache/kafka/pull/14565#discussion_r1370492706
##
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java:
##
@@ -976,15 +1053,14 @@ public void subscribe(Collection topics) {
* Group reba
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1370486899
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PrototypeAsyncConsumer.java:
##
@@ -401,12 +524,12 @@ private void maybeThrowInvalidGroupIdExcepti
Apoorv Mittal created KAFKA-15677:
-
Summary: Add support for re2/j regex parsing for patterns
Key: KAFKA-15677
URL: https://issues.apache.org/jira/browse/KAFKA-15677
Project: Kafka
Issue Type
1 - 100 of 162 matches
Mail list logo
