[
https://issues.apache.org/jira/browse/KAFKA-15159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ezio Xie reassigned KAFKA-15159:
Assignee: Ezio Xie
> Update minor dependencies in preparation for 3.5.1
>
DL1231 commented on code in PR #13969:
URL: https://github.com/apache/kafka/pull/13969#discussion_r1257413847
##
clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java:
##
@@ -250,7 +250,16 @@ public void checkQuotas() {
checkQuotas(time.milliseconds());
DL1231 commented on code in PR #13969:
URL: https://github.com/apache/kafka/pull/13969#discussion_r1257413803
##
clients/src/test/java/org/apache/kafka/common/metrics/SensorTest.java:
##
@@ -366,4 +368,60 @@ public void
testUpdatingMetricConfigIsReflectedInTheSensor() {
eziosudo commented on code in PR #13973:
URL: https://github.com/apache/kafka/pull/13973#discussion_r1257387868
##
streams/src/test/java/org/apache/kafka/streams/integration/MetricsIntegrationTest.java:
##
@@ -68,6 +69,7 @@
@Timeout(600)
@Category({IntegrationTest.class})
abhijeetk88 commented on code in PR #13944:
URL: https://github.com/apache/kafka/pull/13944#discussion_r1257340916
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -158,23 +164,34 @@ public RemoteLogManager(RemoteLogManagerConfig rlmConfig,
abhijeetk88 commented on code in PR #13944:
URL: https://github.com/apache/kafka/pull/13944#discussion_r1257340916
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -158,23 +164,34 @@ public RemoteLogManager(RemoteLogManagerConfig rlmConfig,
[
https://issues.apache.org/jira/browse/KAFKA-15166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash updated KAFKA-15166:
-
Description:
Remote Storage Manager exposes {{deleteLogSegmentData}} API to
[
https://issues.apache.org/jira/browse/KAFKA-15168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash updated KAFKA-15168:
-
Description:
For a partition p0 and a given leader epoch, the remote log
abhijeetk88 commented on PR #13944:
URL: https://github.com/apache/kafka/pull/13944#issuecomment-1627472927
@showuon adding tests for those gauge metrics requires significant changes.
We will need to obtain a handle for the underlying threadpool, submit tasks to
the threadpool, make sure
Kamal Chandraprakash created KAFKA-15168:
Summary: Handle overlapping remote log segments in
RemoteLogMetadata cache
Key: KAFKA-15168
URL: https://issues.apache.org/jira/browse/KAFKA-15168
Kamal Chandraprakash created KAFKA-15167:
Summary: Tiered Storage Test Harness Framework
Key: KAFKA-15167
URL: https://issues.apache.org/jira/browse/KAFKA-15167
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-15166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash updated KAFKA-15166:
-
Parent: KAFKA-7739
Issue Type: Sub-task (was: Task)
> Add
[
https://issues.apache.org/jira/browse/KAFKA-12969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash reassigned KAFKA-12969:
Assignee: Kamal Chandraprakash (was: Satish Duggana)
> Add cluster or
kamalcph commented on PR #13837:
URL: https://github.com/apache/kafka/pull/13837#issuecomment-1627469910
@showuon @divijvaidya
Addressed your review comments. Please take another look. Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message,
abhijeetk88 commented on code in PR #13944:
URL: https://github.com/apache/kafka/pull/13944#discussion_r1257337628
##
core/src/main/scala/kafka/server/KafkaRequestHandler.scala:
##
@@ -277,6 +277,11 @@ class BrokerTopicMetrics(name: Option[String]) {
Kamal Chandraprakash created KAFKA-15166:
Summary: Add deletePartition API to the RemoteStorageManager
Key: KAFKA-15166
URL: https://issues.apache.org/jira/browse/KAFKA-15166
Project: Kafka
Sandeep created KAFKA-15165:
---
Summary: Handle Kafka client certificate failures without
impacting brokers
Key: KAFKA-15165
URL: https://issues.apache.org/jira/browse/KAFKA-15165
Project: Kafka
fvaleri commented on PR #13201:
URL: https://github.com/apache/kafka/pull/13201#issuecomment-1627395334
Hi @OmniaGM.
> Move TopicFilter out of core. (This is part of
https://issues.apache.org/jira/browse/KAFKA-14647 which seems not moving for a
while )
I think #13158 is
fvaleri commented on PR #13310:
URL: https://github.com/apache/kafka/pull/13310#issuecomment-1627393355
This is one of the tools that requires multiple PRs, starting from core's
dependencies migrations.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/KAFKA-14953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17741313#comment-17741313
]
Abhijeet Kumar commented on KAFKA-14953:
[~jeqo] Adding the additional metric for
fvaleri commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1257293747
##
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommandOptions.java:
##
@@ -0,0 +1,177 @@
+/*
+ * Licensed to the Apache Software Foundation
fvaleri commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1257293747
##
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommandOptions.java:
##
@@ -0,0 +1,177 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/KAFKA-14591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-14591:
Fix Version/s: 3.6.0
> Move DeleteRecordsCommand to tools
>
ijuma commented on code in PR #13267:
URL: https://github.com/apache/kafka/pull/13267#discussion_r1257288831
##
core/src/main/scala/kafka/coordinator/transaction/ProducerIdManager.scala:
##
@@ -123,73 +131,103 @@ class ZkProducerIdManager(brokerId: Int,
}
}
- def
[
https://issues.apache.org/jira/browse/KAFKA-14730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17741308#comment-17741308
]
Federico Valeri commented on KAFKA-14730:
-
[~nizhikov] it looks like the PR is closed and
kamalcph commented on code in PR #13969:
URL: https://github.com/apache/kafka/pull/13969#discussion_r1257268739
##
clients/src/test/java/org/apache/kafka/common/metrics/SensorTest.java:
##
@@ -366,4 +368,60 @@ public void
testUpdatingMetricConfigIsReflectedInTheSensor() {
abhijeetk88 commented on code in PR #13944:
URL: https://github.com/apache/kafka/pull/13944#discussion_r1257264600
##
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteStorageThreadPool.java:
##
@@ -41,6 +44,19 @@ public String logPrefix() {
abhijeetk88 commented on code in PR #13944:
URL: https://github.com/apache/kafka/pull/13944#discussion_r1257264233
##
core/src/test/java/kafka/log/remote/RemoteLogReaderTest.java:
##
@@ -61,15 +74,20 @@ public void testRemoteLogReaderWithoutError() throws
abhijeetk88 commented on code in PR #13944:
URL: https://github.com/apache/kafka/pull/13944#discussion_r1257257624
##
core/src/test/java/kafka/log/remote/RemoteLogReaderTest.java:
##
@@ -40,18 +42,29 @@
import static org.mockito.Mockito.when;
public class
abhijeetk88 commented on code in PR #13944:
URL: https://github.com/apache/kafka/pull/13944#discussion_r1257256097
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -951,6 +970,10 @@ public Thread newThread(Runnable r) {
return threadPool;
divijvaidya commented on code in PR #13973:
URL: https://github.com/apache/kafka/pull/13973#discussion_r1257227758
##
streams/src/test/java/org/apache/kafka/streams/integration/MetricsIntegrationTest.java:
##
@@ -68,6 +69,7 @@
@Timeout(600)
[
https://issues.apache.org/jira/browse/KAFKA-15157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya resolved KAFKA-15157.
--
Resolution: Fixed
> Print startup time for RemoteIndexCache
>
[
https://issues.apache.org/jira/browse/KAFKA-15157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15157:
-
Fix Version/s: 3.6.0
> Print startup time for RemoteIndexCache
>
divijvaidya merged PR #13970:
URL: https://github.com/apache/kafka/pull/13970
--
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:
divijvaidya merged PR #13936:
URL: https://github.com/apache/kafka/pull/13936
--
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:
divijvaidya commented on PR #13936:
URL: https://github.com/apache/kafka/pull/13936#issuecomment-1627102695
Unrelated test failures in CI. Merging this one.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
divijvaidya commented on code in PR #13275:
URL: https://github.com/apache/kafka/pull/13275#discussion_r1255762594
##
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java:
##
@@ -0,0 +1,582 @@
+/*
+ * Licensed to the Apache Software Foundation
divijvaidya commented on code in PR #13976:
URL: https://github.com/apache/kafka/pull/13976#discussion_r1257220370
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -113,10 +113,11 @@ class ReplicaManagerTest {
@AfterEach
def tearDown(): Unit = {
rishiraj88 commented on PR #13564:
URL: https://github.com/apache/kafka/pull/13564#issuecomment-1626943287
Thanks, @vcrfxia and @mjsax for insights.
--
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
hudeqi opened a new pull request, #13979:
URL: https://github.com/apache/kafka/pull/13979
move TROGDOR.md in root dir to trogdor module, and rename to README.md
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
yashmayya commented on code in PR #13945:
URL: https://github.com/apache/kafka/pull/13945#discussion_r1257110479
##
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceConnector.java:
##
@@ -101,4 +105,40 @@ public ExactlyOnceSupport exactlyOnceSupport(Map
41 matches
Mail list logo
