[
https://issues.apache.org/jira/browse/KAFKA-13508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741243#comment-17741243
]
Yi-Sheng Lien commented on KAFKA-13508:
---
Hi [~suyashtava] ,
do you mind if I do th
dajac commented on code in PR #13976:
URL: https://github.com/apache/kafka/pull/13976#discussion_r1256903064
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -113,10 +113,11 @@ class ReplicaManagerTest {
@AfterEach
def tearDown(): Unit = {
// v
junrao commented on PR #1864:
URL: https://github.com/apache/kafka/pull/1864#issuecomment-1626345380
@nkostoulas : My vague recollection is that for
ThrottledReplicationRateLimit to take effect, we need to set
[leader.replication.throttled.replicas](https://kafka.apache.org/documentation/#t
junrao commented on PR #13797:
URL: https://github.com/apache/kafka/pull/13797#issuecomment-1626335594
@philipnee Was the following comment addressed? Kirk mentioned to take a
closer look.
https://github.com/apache/kafka/pull/13797#discussion_r1222086968
--
This is an automated mes
jolshan commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1256502612
##
core/src/main/scala/kafka/cluster/Partition.scala:
##
@@ -578,7 +578,7 @@ class Partition(val topicPartition: TopicPartition,
// Returns a verification guard ob
cmccabe merged PR #13940:
URL: https://github.com/apache/kafka/pull/13940
--
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.
gharris1727 commented on code in PR #13945:
URL: https://github.com/apache/kafka/pull/13945#discussion_r1256448988
##
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceConnector.java:
##
@@ -101,4 +105,40 @@ public ExactlyOnceSupport exactlyOnceSupport(Map
Lianet Magrans created KAFKA-15164:
--
Summary: Extract reusable logic from OffsetsForLeaderEpochClient
Key: KAFKA-15164
URL: https://issues.apache.org/jira/browse/KAFKA-15164
Project: Kafka
I
[
https://issues.apache.org/jira/browse/KAFKA-15164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans reassigned KAFKA-15164:
--
Assignee: Lianet Magrans
> Extract reusable logic from OffsetsForLeaderEpochClient
>
mumrah opened a new pull request, #13978:
URL: https://github.com/apache/kafka/pull/13978
Reorder some of the methods and events in this class to match the expected
flow of the migration.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
dajac commented on code in PR #13961:
URL: https://github.com/apache/kafka/pull/13961#discussion_r1256431266
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -190,6 +216,133 @@ boolean canTransitionFrom(CoordinatorState
jeffkbkim commented on code in PR #13961:
URL: https://github.com/apache/kafka/pull/13961#discussion_r1256409668
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -190,6 +216,133 @@ boolean canTransitionFrom(CoordinatorS
dajac merged PR #13961:
URL: https://github.com/apache/kafka/pull/13961
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-14966:
---
Summary: Extract reusable logic from OffsetFetcher (was: Extract reusable
common logic from
[
https://issues.apache.org/jira/browse/KAFKA-15163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15163:
---
Description:
Introduce support for validating positions in the new OffsetsRequestManager.
T
[
https://issues.apache.org/jira/browse/KAFKA-15163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15163:
---
Description:
Introduce support for validating positions in the new OffsetsRequestManager.
T
gharris1727 opened a new pull request, #13977:
URL: https://github.com/apache/kafka/pull/13977
The ClasspathHelper.forJavaClassPath disregards all intermediate
classloaders between the AppClassLoader and the DelegatingClassLoader, when
those classloaders may contain plugins.
Instead,
Lianet Magrans created KAFKA-15163:
--
Summary: Implement validatePositions functionality for new
KafkaConsumer
Key: KAFKA-15163
URL: https://issues.apache.org/jira/browse/KAFKA-15163
Project: Kafka
junrao commented on code in PR #13275:
URL: https://github.com/apache/kafka/pull/13275#discussion_r1256287178
##
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java:
##
@@ -16,6 +16,9 @@
*/
package org.apache.kafka.storage.internals.log;
+impo
junrao commented on code in PR #13275:
URL: https://github.com/apache/kafka/pull/13275#discussion_r1255005974
##
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java:
##
@@ -0,0 +1,582 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
Greg Harris created KAFKA-15162:
---
Summary: Reflective plugin scanning misses plugins which are in
parent classloaders but not classpath
Key: KAFKA-15162
URL: https://issues.apache.org/jira/browse/KAFKA-15162
eziosudo commented on PR #13973:
URL: https://github.com/apache/kafka/pull/13973#issuecomment-1625780465
@divijvaidya Hi, can you help to review this PR?
--
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
jeffkbkim commented on PR #13870:
URL: https://github.com/apache/kafka/pull/13870#issuecomment-1625762579
@dajac @CalvinConfluent
thanks for the review, i have addressed your comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
artemlivshits commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1256175697
##
core/src/main/scala/kafka/cluster/Partition.scala:
##
@@ -578,7 +578,7 @@ class Partition(val topicPartition: TopicPartition,
// Returns a verification gu
jeffkbkim commented on code in PR #13870:
URL: https://github.com/apache/kafka/pull/13870#discussion_r1256163265
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1043,4 +1230,1358 @@ public void onNewMetadataImage(MetadataIm
jeffkbkim commented on code in PR #13870:
URL: https://github.com/apache/kafka/pull/13870#discussion_r1256157423
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1043,4 +1230,1358 @@ public void onNewMetadataImage(MetadataIm
[
https://issues.apache.org/jira/browse/KAFKA-14995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741140#comment-17741140
]
ASF GitHub Bot commented on KAFKA-14995:
stevenbooke commented on PR #521:
URL:
jeffkbkim commented on code in PR #13870:
URL: https://github.com/apache/kafka/pull/13870#discussion_r1256152143
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1043,4 +1230,1358 @@ public void onNewMetadataImage(MetadataIm
wcarlson5 commented on code in PR #13927:
URL: https://github.com/apache/kafka/pull/13927#discussion_r1256076934
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -1619,7 +1639,14 @@ private List standbyTaskIterable() {
}
p
jolshan commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1256141517
##
core/src/main/scala/kafka/cluster/Partition.scala:
##
@@ -578,7 +578,7 @@ class Partition(val topicPartition: TopicPartition,
// Returns a verification guard ob
jolshan commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1256140857
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java:
##
@@ -793,19 +793,18 @@ private void failBatch(
Function recordExceptions,
jolshan commented on code in PR #13961:
URL: https://github.com/apache/kafka/pull/13961#discussion_r1256131904
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -190,6 +216,127 @@ boolean canTransitionFrom(CoordinatorSta
divijvaidya commented on code in PR #13936:
URL: https://github.com/apache/kafka/pull/13936#discussion_r1256126637
##
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentMetadata.java:
##
@@ -100,7 +100,16 @@ public RemoteLogSegmentMetadata(Remot
jeffkbkim commented on code in PR #13870:
URL: https://github.com/apache/kafka/pull/13870#discussion_r1256110776
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1043,4 +1230,1358 @@ public void onNewMetadataImage(MetadataIm
divijvaidya commented on code in PR #13936:
URL: https://github.com/apache/kafka/pull/13936#discussion_r1256109183
##
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentMetadata.java:
##
@@ -100,7 +100,16 @@ public RemoteLogSegmentMetadata(Remot
dajac commented on code in PR #13961:
URL: https://github.com/apache/kafka/pull/13961#discussion_r1256105702
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -190,6 +216,127 @@ boolean canTransitionFrom(CoordinatorState
jolshan commented on code in PR #13961:
URL: https://github.com/apache/kafka/pull/13961#discussion_r1256096167
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -190,6 +216,127 @@ boolean canTransitionFrom(CoordinatorSta
dajac commented on code in PR #13961:
URL: https://github.com/apache/kafka/pull/13961#discussion_r1256092728
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -190,6 +216,127 @@ boolean canTransitionFrom(CoordinatorState
[
https://issues.apache.org/jira/browse/KAFKA-15137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741123#comment-17741123
]
Alyssa Huang commented on KAFKA-15137:
--
I'll do this in the next few days!
> Don't
jolshan commented on code in PR #13961:
URL: https://github.com/apache/kafka/pull/13961#discussion_r1256084088
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntimeTest.java:
##
@@ -893,4 +1041,250 @@ public void testOnNewMetadataImage(
satishd commented on code in PR #13936:
URL: https://github.com/apache/kafka/pull/13936#discussion_r1256079424
##
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentMetadata.java:
##
@@ -100,7 +100,16 @@ public RemoteLogSegmentMetadata(RemoteLog
jolshan commented on code in PR #13961:
URL: https://github.com/apache/kafka/pull/13961#discussion_r1256075348
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -190,6 +216,127 @@ boolean canTransitionFrom(CoordinatorSta
jeffkbkim commented on code in PR #13870:
URL: https://github.com/apache/kafka/pull/13870#discussion_r1256069184
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -150,19 +215,39 @@ GroupMetadataManager build() {
jeffkbkim commented on code in PR #13870:
URL: https://github.com/apache/kafka/pull/13870#discussion_r1256056130
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -266,9 +285,31 @@ public CompletableFuture joinGroup(
jeffkbkim commented on code in PR #13870:
URL: https://github.com/apache/kafka/pull/13870#discussion_r1256037213
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -874,4 +1087,1362 @@ public void replay(
consumerG
DL1231 commented on code in PR #13970:
URL: https://github.com/apache/kafka/pull/13970#discussion_r1256028383
##
core/src/main/scala/kafka/log/remote/RemoteIndexCache.scala:
##
@@ -178,6 +178,7 @@ class RemoteIndexCache(maxSize: Int = 1024,
remoteStorageManager: RemoteStorageM
divijvaidya commented on PR #13976:
URL: https://github.com/apache/kafka/pull/13976#issuecomment-1625584575
@jolshan since you reviewed #13868, would you also kindle review this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
divijvaidya commented on PR #13956:
URL: https://github.com/apache/kafka/pull/13956#issuecomment-1625580951
@jolshan would you like to take a look at this?
--
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
[
https://issues.apache.org/jira/browse/KAFKA-15137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741086#comment-17741086
]
Divij Vaidya commented on KAFKA-15137:
--
Hey [~alyssahuang]
We are planning a relea
[
https://issues.apache.org/jira/browse/KAFKA-14705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-14705:
Description:
We can use this task to track tools cleanup for the next major release (4.0.0
[
https://issues.apache.org/jira/browse/KAFKA-14705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-14705:
Summary: Tools cleanup for the next major release (was: Remove tools
redirections and dep
[
https://issues.apache.org/jira/browse/KAFKA-14705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-14705:
Description:
We can use this task to track cleanup actions for the next major release
(4.
[
https://issues.apache.org/jira/browse/KAFKA-14705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-14705:
Description:
We can use this task to track cleanup actions for the next major release
(4.
fvaleri commented on code in PR #13417:
URL: https://github.com/apache/kafka/pull/13417#discussion_r1255759422
##
tools/src/main/java/org/apache/kafka/tools/StorageTool.java:
##
@@ -0,0 +1,309 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * cont
viktorsomogyi commented on PR #13975:
URL: https://github.com/apache/kafka/pull/13975#issuecomment-1625537914
@cmccabe @mumrah would you please review it too?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
divijvaidya commented on code in PR #13970:
URL: https://github.com/apache/kafka/pull/13970#discussion_r1254621897
##
core/src/main/scala/kafka/log/remote/RemoteIndexCache.scala:
##
@@ -178,6 +178,7 @@ class RemoteIndexCache(maxSize: Int = 1024,
remoteStorageManager: RemoteStor
divijvaidya commented on PR #13970:
URL: https://github.com/apache/kafka/pull/13970#issuecomment-1625531583
@satishd FYI, this is also a candidate to be incorporated into
https://github.com/apache/kafka/pull/13275
--
This is an automated message from the Apache Git Service.
To respond to
divijvaidya merged PR #13972:
URL: https://github.com/apache/kafka/pull/13972
--
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.apa
viktorsomogyi commented on PR #13975:
URL: https://github.com/apache/kafka/pull/13975#issuecomment-1625509630
@urbandan would you please review it as well?
--
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
viktorsomogyi opened a new pull request, #13975:
URL: https://github.com/apache/kafka/pull/13975
In certain very specific cases a constellation can occur when Connect isn't
able to get topic metadata when the brokers are being in a rolling restart.
To make both the broker and the java
[
https://issues.apache.org/jira/browse/KAFKA-15149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Grant resolved KAFKA-15149.
--
Resolution: Fixed
> Fix not sending UMR and LISR RPCs in dual-write mode when there are new
>
dajac commented on PR #13870:
URL: https://github.com/apache/kafka/pull/13870#issuecomment-1625488949
There are issues with the build as well. Could you look into this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
mumrah merged PR #13968:
URL: https://github.com/apache/kafka/pull/13968
--
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-15161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viktor Somogyi-Vass updated KAFKA-15161:
Description:
h2. Problem description
In our system test environment in certain ca
[
https://issues.apache.org/jira/browse/KAFKA-14995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741039#comment-17741039
]
ASF GitHub Bot commented on KAFKA-14995:
mimaison commented on PR #521:
URL: htt
Purely-Jonas commented on PR #13865:
URL: https://github.com/apache/kafka/pull/13865#issuecomment-1625415319
Just voicing our want - at Dixa - for a 3.4.x version release. Thank you for
all the great work you put into this!
--
This is an automated message from the Apache Git Service.
To r
dajac commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1255784243
##
core/src/main/scala/kafka/cluster/Partition.scala:
##
@@ -578,7 +578,7 @@ class Partition(val topicPartition: TopicPartition,
// Returns a verification guard obje
dajac commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1255783931
##
core/src/main/scala/kafka/cluster/Partition.scala:
##
@@ -578,7 +578,7 @@ class Partition(val topicPartition: TopicPartition,
// Returns a verification guard obje
dajac commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1255779604
##
server-common/src/main/java/org/apache/kafka/server/util/InterBrokerSendThread.java:
##
@@ -118,6 +118,11 @@ protected void pollOnce(long maxTimeoutMs) {
dajac commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1255778900
##
server-common/src/main/java/org/apache/kafka/server/util/InterBrokerSendThread.java:
##
@@ -118,6 +118,11 @@ protected void pollOnce(long maxTimeoutMs) {
divijvaidya commented on code in PR #13936:
URL: https://github.com/apache/kafka/pull/13936#discussion_r1255777691
##
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentMetadata.java:
##
@@ -100,7 +100,16 @@ public RemoteLogSegmentMetadata(Remot
[
https://issues.apache.org/jira/browse/KAFKA-15161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viktor Somogyi-Vass updated KAFKA-15161:
Description:
h2. Problem description
In our system test environment in certain ca
dajac commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1255775822
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java:
##
@@ -793,19 +793,18 @@ private void failBatch(
Function recordExceptions,
aneelkkhatri commented on PR #13972:
URL: https://github.com/apache/kafka/pull/13972#issuecomment-1625358965
> Hey @aneelkkhatri Thank you for your first contribution to Apache Kafka!
Since this is the first time, I would take this opportunity to suggest you to
read the contributing guideli
[
https://issues.apache.org/jira/browse/KAFKA-15161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viktor Somogyi-Vass updated KAFKA-15161:
Description:
h2. Problem description
In our system test environment in certain ca
divijvaidya commented on code in PR #13275:
URL: https://github.com/apache/kafka/pull/13275#discussion_r1255757382
##
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java:
##
@@ -16,6 +16,9 @@
*/
package org.apache.kafka.storage.internals.log;
jeqo commented on code in PR #13936:
URL: https://github.com/apache/kafka/pull/13936#discussion_r1255748772
##
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentMetadata.java:
##
@@ -100,7 +100,16 @@ public RemoteLogSegmentMetadata(RemoteLogSeg
[
https://issues.apache.org/jira/browse/KAFKA-14581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-14581:
-
Assignee: Ruslan Krivoshein
> Move GetOffsetShell to tools
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-15094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17740997#comment-17740997
]
Divij Vaidya commented on KAFKA-15094:
--
[https://github.com/ben-manes/caffeine/wiki
[
https://issues.apache.org/jira/browse/KAFKA-15161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viktor Somogyi-Vass updated KAFKA-15161:
Attachment: empty_metadata.patch
> InvalidReplicationFactorException at connect st
[
https://issues.apache.org/jira/browse/KAFKA-15161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viktor Somogyi-Vass updated KAFKA-15161:
Issue Type: Bug (was: Improvement)
> InvalidReplicationFactorException at connect
[
https://issues.apache.org/jira/browse/KAFKA-15161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viktor Somogyi-Vass updated KAFKA-15161:
Description:
h2. Problem description
In our system test environment in certain ca
[
https://issues.apache.org/jira/browse/KAFKA-15161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viktor Somogyi-Vass reassigned KAFKA-15161:
---
Assignee: Viktor Somogyi-Vass
> InvalidReplicationFactorException at connec
Viktor Somogyi-Vass created KAFKA-15161:
---
Summary: InvalidReplicationFactorException at connect startup
Key: KAFKA-15161
URL: https://issues.apache.org/jira/browse/KAFKA-15161
Project: Kafka
divijvaidya commented on code in PR #13936:
URL: https://github.com/apache/kafka/pull/13936#discussion_r1255713117
##
core/src/main/scala/kafka/log/remote/RemoteIndexCache.scala:
##
@@ -38,7 +38,60 @@ import java.util.concurrent.locks.ReentrantReadWriteLock
object RemoteIndexCa
vamossagar12 commented on code in PR #13955:
URL: https://github.com/apache/kafka/pull/13955#discussion_r1255698936
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTaskTest.java:
##
@@ -651,6 +652,40 @@ public void
testTopicCreateSucceedsWh
vamossagar12 commented on code in PR #13801:
URL: https://github.com/apache/kafka/pull/13801#discussion_r1255692148
##
connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStore.java:
##
@@ -279,8 +284,60 @@ public Future set(Map
values, Callback
vamossagar12 commented on code in PR #13801:
URL: https://github.com/apache/kafka/pull/13801#discussion_r1255690496
##
checkstyle/suppressions.xml:
##
@@ -154,7 +154,7 @@
files="(KafkaConfigBackingStore|Values|ConnectMetricsRegistry).java"/>
+
vamossagar12 commented on code in PR #13801:
URL: https://github.com/apache/kafka/pull/13801#discussion_r1255687711
##
connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStore.java:
##
@@ -279,8 +284,60 @@ public Future set(Map
values, Callback
cxorm commented on PR #13974:
URL: https://github.com/apache/kafka/pull/13974#issuecomment-1625237314
> Please feel to fix it in this PR.
Fixed all places related to this Jira,
Would you be so kind as to take a look at this PR if you have time?
--
This is an automated message fr
satishd commented on code in PR #13936:
URL: https://github.com/apache/kafka/pull/13936#discussion_r1255603306
##
core/src/main/scala/kafka/log/remote/RemoteIndexCache.scala:
##
@@ -38,7 +38,60 @@ import java.util.concurrent.locks.ReentrantReadWriteLock
object RemoteIndexCache
fvaleri commented on code in PR #13562:
URL: https://github.com/apache/kafka/pull/13562#discussion_r1255510339
##
tools/src/main/java/org/apache/kafka/tools/GetOffsetShell.java:
##
@@ -0,0 +1,340 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * c
hudeqi commented on PR #13946:
URL: https://github.com/apache/kafka/pull/13946#issuecomment-1625191011
and this, thanks. @C0urante
--
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 #13913:
URL: https://github.com/apache/kafka/pull/13913#issuecomment-1625189960
pin again @C0urante
--
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.
fvaleri commented on PR #13214:
URL: https://github.com/apache/kafka/pull/13214#issuecomment-1625147370
Hi @Hangleton, what's the state of this PR? Let me know if you need some
help/review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/KAFKA-14576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17740959#comment-17740959
]
Federico Valeri commented on KAFKA-14576:
-
[~christo_lolov] I see this is in pro
yashmayya commented on code in PR #13955:
URL: https://github.com/apache/kafka/pull/13955#discussion_r1255540020
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTaskTest.java:
##
@@ -651,6 +652,40 @@ public void
testTopicCreateSucceedsWhenC
[
https://issues.apache.org/jira/browse/KAFKA-14647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-14647:
Fix Version/s: 3.6.0
> Move TopicFilter shared class
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-14581:
Fix Version/s: 3.6.0
> Move GetOffsetShell to tools
>
>
>
yashmayya commented on code in PR #13955:
URL: https://github.com/apache/kafka/pull/13955#discussion_r1255540020
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTaskTest.java:
##
@@ -651,6 +652,40 @@ public void
testTopicCreateSucceedsWhenC
1 - 100 of 117 matches
Mail list logo