clolov commented on code in PR #14161:
URL: https://github.com/apache/kafka/pull/14161#discussion_r1294261443
##
core/src/main/scala/kafka/server/ConfigHandler.scala:
##
@@ -62,6 +62,12 @@ class TopicConfigHandler(private val logManager: LogManager,
kafkaConfig: KafkaC
top
clolov commented on code in PR #14161:
URL: https://github.com/apache/kafka/pull/14161#discussion_r1294263440
##
core/src/main/scala/kafka/server/ConfigHandler.scala:
##
@@ -62,6 +62,12 @@ class TopicConfigHandler(private val logManager: LogManager,
kafkaConfig: KafkaC
top
clolov commented on code in PR #14204:
URL: https://github.com/apache/kafka/pull/14204#discussion_r1294265668
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableTransformValuesTest.java:
##
@@ -163,104 +159,74 @@ public void shouldNotSendOldValuesByDefault
clolov commented on PR #14136:
URL: https://github.com/apache/kafka/pull/14136#issuecomment-1678516932
To provide some clarity, I will just do one more pass for the MetadataCache
itself, because I would like to confirm that it is updated when we would expect
it to be (as per Divij's comment
showuon commented on code in PR #14161:
URL: https://github.com/apache/kafka/pull/14161#discussion_r1294276490
##
core/src/main/scala/kafka/server/ConfigHandler.scala:
##
@@ -62,6 +62,12 @@ class TopicConfigHandler(private val logManager: LogManager,
kafkaConfig: KafkaC
to
lucasbru commented on code in PR #13927:
URL: https://github.com/apache/kafka/pull/13927#discussion_r1294315120
##
streams/src/test/java/org/apache/kafka/streams/integration/PurgeRepartitionTopicIntegrationTest.java:
##
@@ -212,10 +213,11 @@ public void shouldRestoreState() thro
cadonna commented on code in PR #13927:
URL: https://github.com/apache/kafka/pull/13927#discussion_r1294331015
##
streams/src/test/java/org/apache/kafka/streams/integration/PurgeRepartitionTopicIntegrationTest.java:
##
@@ -212,10 +213,11 @@ public void shouldRestoreState() throw
vamossagar12 commented on code in PR #14202:
URL: https://github.com/apache/kafka/pull/14202#discussion_r1294357019
##
storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfigTest.java:
##
@@ -52,6 +54,28 @@ public void testValidConfigs() {
vamossagar12 commented on PR #14202:
URL: https://github.com/apache/kafka/pull/14202#issuecomment-1678631384
Thanks @showuon , I made the requested changes.
--
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-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov updated KAFKA-14133:
--
Description:
{color:#de350b}There are tests which use both PowerMock and EasyMock. I have
put
showuon commented on code in PR #14202:
URL: https://github.com/apache/kafka/pull/14202#discussion_r1294388761
##
storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfigTest.java:
##
@@ -32,21 +36,28 @@ public TestConfig(Map originals) {
divijvaidya merged PR #14190:
URL: https://github.com/apache/kafka/pull/14190
--
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
divijvaidya commented on code in PR #14135:
URL: https://github.com/apache/kafka/pull/14135#discussion_r1294402358
##
core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala:
##
@@ -121,16 +122,18 @@ class PlaintextProducerSendTest extends
BaseProducerSendTest
OmniaGM commented on code in PR #14082:
URL: https://github.com/apache/kafka/pull/14082#discussion_r1294402558
##
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/DefaultReplicationPolicy.java:
##
@@ -43,6 +47,11 @@ public void configure(Map props) {
OmniaGM commented on code in PR #14082:
URL: https://github.com/apache/kafka/pull/14082#discussion_r1294403336
##
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/DefaultReplicationPolicy.java:
##
@@ -43,6 +47,11 @@ public void configure(Map props) {
vamossagar12 commented on PR #14202:
URL: https://github.com/apache/kafka/pull/14202#issuecomment-1678684041
Thanks Luke. I corrected.
--
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
vamossagar12 commented on code in PR #14202:
URL: https://github.com/apache/kafka/pull/14202#discussion_r1294406054
##
storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfigTest.java:
##
@@ -32,21 +36,28 @@ public TestConfig(Map originals) {
divijvaidya commented on PR #14176:
URL: https://github.com/apache/kafka/pull/14176#issuecomment-1678685831
@kamalcph Tests from this PR are failing in CI such as
`RemoteTopicCrudTest.testEnableRemoteLogOnExistingTopicTest`, see:
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-14
divijvaidya commented on code in PR #14176:
URL: https://github.com/apache/kafka/pull/14176#discussion_r1294410814
##
storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java:
##
@@ -265,7 +266,12 @@ public Optional serverConfigName(String
configName) {
clolov opened a new pull request, #14209:
URL: https://github.com/apache/kafka/pull/14209
This pull requests migrates mocks from ActiveTaskCreatorTest,
ChangelogTopicsTest and GlobalProcessorContextImplTest to Mockito.
--
This is an automated message from the Apache Git Service.
To re
nizhikov commented on PR #13247:
URL: https://github.com/apache/kafka/pull/13247#issuecomment-1678700485
@mimaison Is there any change that PR will be reviewed in current shape? Or
I should think on how split it?
--
This is an automated message from the Apache Git Service.
To respond to t
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov updated KAFKA-14133:
--
Description:
{color:#de350b}There are tests which use both PowerMock and EasyMock. I have
put
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov updated KAFKA-14133:
--
Description:
{color:#de350b}There are tests which use both PowerMock and EasyMock. I have
put
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov updated KAFKA-14133:
--
Description:
{color:#de350b}There are tests which use both PowerMock and EasyMock. I have
put
[
https://issues.apache.org/jira/browse/KAFKA-15172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754541#comment-17754541
]
hudeqi commented on KAFKA-15172:
This KIP is seldom discussed, what should I do next? [~
clolov opened a new pull request, #14210:
URL: https://github.com/apache/kafka/pull/14210
This pull requests migrates mocks from RecordCollectorTest,
StateRestoreCallbackAdapterTest and StoreToProcessorContextAdapterTest to
Mockito.
--
This is an automated message from the Apache Git Ser
Nickstery commented on code in PR #14104:
URL: https://github.com/apache/kafka/pull/14104#discussion_r1294052739
##
storage/src/main/java/org/apache/kafka/storage/internals/log/TimeIndex.java:
##
@@ -72,15 +72,17 @@ public TimeIndex(File file, long baseOffset, int
maxIndexSize,
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nelson B. updated KAFKA-14133:
--
Description:
{color:#de350b}There are tests which use both PowerMock and EasyMock. I have
put those i
OmniaGM commented on code in PR #13204:
URL: https://github.com/apache/kafka/pull/13204#discussion_r1294455490
##
tools/src/test/java/org/apache/kafka/tools/LeaderElectionCommandTest.java:
##
@@ -0,0 +1,329 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
OmniaGM commented on code in PR #13204:
URL: https://github.com/apache/kafka/pull/13204#discussion_r1294455955
##
tools/src/test/java/org/apache/kafka/tools/LeaderElectionCommandTest.java:
##
@@ -0,0 +1,329 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
OmniaGM commented on code in PR #13204:
URL: https://github.com/apache/kafka/pull/13204#discussion_r1294456310
##
tools/src/main/java/org/apache/kafka/tools/LeaderElectionCommand.java:
##
@@ -0,0 +1,376 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mor
OmniaGM commented on code in PR #13204:
URL: https://github.com/apache/kafka/pull/13204#discussion_r1294456594
##
tools/src/test/java/org/apache/kafka/tools/LeaderElectionCommandErrorTest.java:
##
@@ -0,0 +1,90 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under on
OmniaGM commented on code in PR #13204:
URL: https://github.com/apache/kafka/pull/13204#discussion_r1294460465
##
tools/src/test/java/org/apache/kafka/tools/LeaderElectionCommandTest.java:
##
@@ -0,0 +1,329 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
OmniaGM commented on code in PR #13204:
URL: https://github.com/apache/kafka/pull/13204#discussion_r1294460859
##
tools/src/test/java/org/apache/kafka/tools/LeaderElectionCommandTest.java:
##
@@ -0,0 +1,329 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
OmniaGM commented on code in PR #13204:
URL: https://github.com/apache/kafka/pull/13204#discussion_r1294461075
##
tools/src/test/java/org/apache/kafka/tools/LeaderElectionCommandTest.java:
##
@@ -0,0 +1,329 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
see-quick opened a new pull request, #14211:
URL: https://github.com/apache/kafka/pull/14211
This PR adds a few test cases to clients, increasing test coverage a little
bit.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Ver
kamalcph commented on code in PR #14116:
URL: https://github.com/apache/kafka/pull/14116#discussion_r1294503554
##
storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestContext.java:
##
@@ -0,0 +1,339 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
viktorsomogyi commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1294522714
##
metadata/src/main/java/org/apache/kafka/controller/DelegationTokenControlManager.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation
divijvaidya commented on PR #14116:
URL: https://github.com/apache/kafka/pull/14116#issuecomment-1678871025
@kamalcph changes look good to me. Let's focus on CI build now. Could you
please fix the checkstyle failures which are causing build failures?
--
This is an automated message from t
showuon commented on code in PR #14116:
URL: https://github.com/apache/kafka/pull/14116#discussion_r1294548425
##
storage/src/test/java/org/apache/kafka/tiered/storage/README.md:
##
@@ -0,0 +1,9 @@
+Step 1: For every test, setup is done via TieredStorageTestHarness which
extend
David Mao created KAFKA-15344:
-
Summary: Kafka Streams should include the message leader epoch
when committing offsets
Key: KAFKA-15344
URL: https://issues.apache.org/jira/browse/KAFKA-15344
Project: Kafk
clolov commented on code in PR #14104:
URL: https://github.com/apache/kafka/pull/14104#discussion_r1294565080
##
core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java:
##
@@ -478,23 +498,45 @@ void testMetricsUpdateOnCopyLogSegmentsFailure() throws
Exception {
kamalcph commented on code in PR #14116:
URL: https://github.com/apache/kafka/pull/14116#discussion_r1294583210
##
storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestContext.java:
##
@@ -0,0 +1,348 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
[
https://issues.apache.org/jira/browse/KAFKA-15201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754643#comment-17754643
]
Gantigmaa Selenge commented on KAFKA-15201:
---
Hi [~divijvaidya] I could not rep
satishd commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1294602887
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -698,11 +707,329 @@ public void run() {
}
}
+public void handleLogSt
satishd commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1294603142
##
core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java:
##
@@ -1003,6 +1015,134 @@ public RemoteLogMetadataManager
createRemoteLogMetadataManager() {
satishd commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1294604024
##
core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java:
##
@@ -1003,6 +1015,134 @@ public RemoteLogMetadataManager
createRemoteLogMetadataManager() {
kamalcph commented on code in PR #14116:
URL: https://github.com/apache/kafka/pull/14116#discussion_r1294609562
##
storage/src/test/java/org/apache/kafka/tiered/storage/README.md:
##
@@ -0,0 +1,9 @@
+Step 1: For every test, setup is done via TieredStorageTestHarness which
exten
jeqo commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1294618085
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -1033,6 +1360,35 @@ public void close() {
}
}
+private static class RetentionSizeDa
nikramakrishnan opened a new pull request, #14212:
URL: https://github.com/apache/kafka/pull/14212
This PR adds a test case for follower fetch when segments are archived and
expired from remote storage. This test case verifies the following scenario
(from [comment](https://github.com/apache
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1294623852
##
core/src/main/scala/kafka/server/ControllerApis.scala:
##
@@ -842,6 +847,75 @@ class ControllerApis(val requestChannel: RequestChannel,
}
}
+ def ha
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1294624738
##
core/src/main/scala/kafka/server/ControllerApis.scala:
##
@@ -842,6 +847,75 @@ class ControllerApis(val requestChannel: RequestChannel,
}
}
+ def ha
kamalcph commented on code in PR #14116:
URL: https://github.com/apache/kafka/pull/14116#discussion_r1294640475
##
storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestHarness.java:
##
@@ -0,0 +1,204 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1294648669
##
core/src/main/scala/kafka/server/DelegationTokenManager.scala:
##
@@ -186,57 +133,28 @@ class DelegationTokenManager(val config: KafkaConfig,
val tokenMaxLife
kamalcph commented on PR #14116:
URL: https://github.com/apache/kafka/pull/14116#issuecomment-1679001860
@divijvaidya
Addressed most of your comments and marked them as resolved. Please take a
look that those comments are addressed as expected. Thanks!
--
This is an automated mess
kamalcph commented on code in PR #14116:
URL: https://github.com/apache/kafka/pull/14116#discussion_r1294653156
##
storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestReport.java:
##
@@ -0,0 +1,76 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
divijvaidya commented on code in PR #14116:
URL: https://github.com/apache/kafka/pull/14116#discussion_r1294668715
##
storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestContext.java:
##
@@ -0,0 +1,322 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
divijvaidya commented on PR #14176:
URL: https://github.com/apache/kafka/pull/14176#issuecomment-1679031173
@kamalcph tests are still failing
[RemoteTopicCrudTest.testCreateRemoteTopicWithValidRetentionTime(String).quorum=kraft](https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-1417
kamalcph commented on code in PR #14176:
URL: https://github.com/apache/kafka/pull/14176#discussion_r1294681683
##
core/src/test/scala/integration/kafka/admin/RemoteTopicCrudTest.scala:
##
@@ -0,0 +1,331 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or m
José Armando García Sancio created KAFKA-15345:
--
Summary: KRaft leader should notify the listener only when it has
read up to the leader's epoch
Key: KAFKA-15345
URL: https://issues.apache.org/jira/br
jsancio opened a new pull request, #14213:
URL: https://github.com/apache/kafka/pull/14213
In a non-empty log the KRaft leader only notifies the listener of leadership
when it has read to the leader's epoch start offset. This guarantees that the
leader epoch has been committed and that the
kamalcph commented on code in PR #14176:
URL: https://github.com/apache/kafka/pull/14176#discussion_r1294681683
##
core/src/test/scala/integration/kafka/admin/RemoteTopicCrudTest.scala:
##
@@ -0,0 +1,331 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or m
cadonna opened a new pull request, #14214:
URL: https://github.com/apache/kafka/pull/14214
A stream thread should only change to RUNNING if there are no active tasks
in restoration in the state updater and if there are no pending tasks to
recycle and to init.
Usually all pending task
cadonna commented on code in PR #14214:
URL: https://github.com/apache/kafka/pull/14214#discussion_r1294741387
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TasksRegistry.java:
##
@@ -53,9 +53,11 @@ public interface TasksRegistry {
void addPendingT
cadonna commented on code in PR #14214:
URL: https://github.com/apache/kafka/pull/14214#discussion_r1294742218
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TasksRegistry.java:
##
@@ -53,9 +53,11 @@ public interface TasksRegistry {
void addPendingT
C0urante commented on code in PR #14195:
URL: https://github.com/apache/kafka/pull/14195#discussion_r1294745531
##
tools/src/main/java/org/apache/kafka/tools/ManifestWorkspace.java:
##
@@ -0,0 +1,573 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
cadonna commented on code in PR #14214:
URL: https://github.com/apache/kafka/pull/14214#discussion_r1294745792
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -838,15 +841,15 @@ private void transitRestoredTaskToRunning(final Task ta
C0urante commented on code in PR #14195:
URL: https://github.com/apache/kafka/pull/14195#discussion_r1294750935
##
tools/src/main/java/org/apache/kafka/tools/ManifestWorkspace.java:
##
@@ -0,0 +1,573 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
viktorsomogyi commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1294548060
##
core/src/main/scala/kafka/server/metadata/DelegationTokenPublisher.scala:
##
@@ -0,0 +1,83 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under o
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1294766805
##
server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java:
##
@@ -173,11 +173,14 @@ public enum MetadataVersion {
// Adds replica epoc
C0urante commented on code in PR #14195:
URL: https://github.com/apache/kafka/pull/14195#discussion_r1294779885
##
tools/src/test/java/org/apache/kafka/tools/ConnectPluginPathTest.java:
##
@@ -204,24 +353,25 @@ private static void
assertPluginsAreCompatible(Map> table
lucasbru commented on code in PR #13927:
URL: https://github.com/apache/kafka/pull/13927#discussion_r1294820451
##
streams/src/test/java/org/apache/kafka/streams/integration/PurgeRepartitionTopicIntegrationTest.java:
##
@@ -212,10 +213,11 @@ public void shouldRestoreState() thro
AndrewJSchofield commented on PR #14111:
URL: https://github.com/apache/kafka/pull/14111#issuecomment-1679210703
@junrao Rebased and rebuilt. Please take another look.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
jeqo commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1294829317
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -1033,6 +1365,35 @@ public void close() {
}
}
+private static class RetentionSizeDa
[
https://issues.apache.org/jira/browse/KAFKA-15338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15338:
Labels: beginner newbie (was: )
> The metric group documentation for metrics added in KAF
[
https://issues.apache.org/jira/browse/KAFKA-15319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15319:
Fix Version/s: 3.6.0
> Upgrade rocksdb to fix CVE-2022-37434
> ---
[
https://issues.apache.org/jira/browse/KAFKA-15319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-15319:
---
Assignee: Lucas Brutschy
> Upgrade rocksdb to fix CVE-2022-37434
>
satishd commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1294843843
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -152,16 +152,42 @@ class UnifiedLog(@volatile var logStartOffset: Long,
locally {
initializePartitionMe
divijvaidya commented on code in PR #14176:
URL: https://github.com/apache/kafka/pull/14176#discussion_r1294846904
##
core/src/test/scala/integration/kafka/admin/RemoteTopicCrudTest.scala:
##
@@ -0,0 +1,331 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one o
Alieh Saeedi created KAFKA-15346:
Summary: Single-Key_single-multi-timestamp IQs with versioned
state stores
Key: KAFKA-15346
URL: https://issues.apache.org/jira/browse/KAFKA-15346
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi reassigned KAFKA-15346:
Assignee: Alieh Saeedi
> Single-Key_single-multi-timestamp IQs with versioned state store
[
https://issues.apache.org/jira/browse/KAFKA-15346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi updated KAFKA-15346:
-
Description:
[KIP-960|https://cwiki.apache.org/confluence/display/KAFKA/KIP-960%3A+Support+singl
divijvaidya commented on code in PR #13947:
URL: https://github.com/apache/kafka/pull/13947#discussion_r1294768292
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -343,21 +345,80 @@ public void onLeadershipChange(Set
partitionsBecomeLeader,
/**
*
[
https://issues.apache.org/jira/browse/KAFKA-15346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi updated KAFKA-15346:
-
Description:
[KIP-960|https://cwiki.apache.org/confluence/display/KAFKA/KIP-960%3A+Support+singl
[
https://issues.apache.org/jira/browse/KAFKA-15346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi updated KAFKA-15346:
-
Summary: Single-Key_single-timestamp IQs with versioned state stores (was:
Single-Key_single-mu
Alieh Saeedi created KAFKA-15347:
Summary: Single-Key_multi-timestamp IQs with versioned state stores
Key: KAFKA-15347
URL: https://issues.apache.org/jira/browse/KAFKA-15347
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-15348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi reassigned KAFKA-15348:
Assignee: Alieh Saeedi
> Range IQs with versioned state stores
>
Alieh Saeedi created KAFKA-15348:
Summary: Range IQs with versioned state stores
Key: KAFKA-15348
URL: https://issues.apache.org/jira/browse/KAFKA-15348
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-15347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi reassigned KAFKA-15347:
Assignee: Alieh Saeedi
> Single-Key_multi-timestamp IQs with versioned state stores
> ---
[
https://issues.apache.org/jira/browse/KAFKA-15257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi updated KAFKA-15257:
-
Description:
Query types to consider include:
* single-key latest-value lookup
* single-key lo
divijvaidya commented on code in PR #14176:
URL: https://github.com/apache/kafka/pull/14176#discussion_r1294874991
##
core/src/test/scala/integration/kafka/admin/RemoteTopicCrudTest.scala:
##
@@ -0,0 +1,331 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one o
[
https://issues.apache.org/jira/browse/KAFKA-15344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15344:
Component/s: streams
> Kafka Streams should include the message leader epoch when committi
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya updated KAFKA-14133:
---
Description:
{color:#de350b}There are tests which use both PowerMock and EasyMock. I have
put those
junrao commented on code in PR #14111:
URL: https://github.com/apache/kafka/pull/14111#discussion_r1294873505
##
clients/src/main/java/org/apache/kafka/clients/Metadata.java:
##
@@ -114,18 +125,39 @@ public synchronized Cluster fetch() {
/**
* Return the next time w
junrao commented on code in PR #14111:
URL: https://github.com/apache/kafka/pull/14111#discussion_r1294883198
##
clients/src/main/java/org/apache/kafka/clients/Metadata.java:
##
@@ -140,17 +172,34 @@ public long metadataExpireMs() {
}
/**
- * Request an update of
junrao commented on code in PR #14111:
URL: https://github.com/apache/kafka/pull/14111#discussion_r1294877936
##
clients/src/main/java/org/apache/kafka/clients/Metadata.java:
##
@@ -267,11 +307,14 @@ public synchronized void update(int requestVersion,
MetadataResponse response,
AndrewJSchofield commented on PR #14111:
URL: https://github.com/apache/kafka/pull/14111#issuecomment-1679338770
@junrao I don't know what's causing so many test failures. 78 of them were
due to "unexpected threads" in the broker. I'll take another look when there's
another build. I expect
[
https://issues.apache.org/jira/browse/KAFKA-15344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Mao updated KAFKA-15344:
--
Description:
We noticed an application received an OFFSET_OUT_OF_RANGE error following a
network part
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya updated KAFKA-14133:
---
Description:
{color:#de350b}There are tests which use both PowerMock and EasyMock. I have
put those
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya updated KAFKA-14133:
---
Description:
{color:#de350b}There are tests which use both PowerMock and EasyMock. I have
put those
1 - 100 of 183 matches
Mail list logo
