[
https://issues.apache.org/jira/browse/KAFKA-15376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15376:
---
Summary: Explore options of removing data earlier to the current leader's
leader epoch linea
[
https://issues.apache.org/jira/browse/KAFKA-15339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755812#comment-17755812
]
Sagar Rao edited comment on KAFKA-15339 at 8/18/23 5:52 AM:
[
https://issues.apache.org/jira/browse/KAFKA-15339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755812#comment-17755812
]
Sagar Rao commented on KAFKA-15339:
---
Thanks for reporting this bug [~functioner]. As y
satishd commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1298027732
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -696,11 +704,327 @@ public void run() {
}
}
+public void handleLogSt
Satish Duggana created KAFKA-15376:
--
Summary: Revisit removing data earlier to the current leader for
topics enabled with tiered storage.
Key: KAFKA-15376
URL: https://issues.apache.org/jira/browse/KAFKA-15376
[
https://issues.apache.org/jira/browse/KAFKA-15376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15376:
---
Summary: Explore options of removing data earlier to the current leader for
topics enabled w
satishd commented on PR #13947:
URL: https://github.com/apache/kafka/pull/13947#issuecomment-1683388925
I will merge the PR to unblock other integration test related PRs as it has
got 2 +1s(Jun and me). Remaining items if any can be addressed in followup PRs.
--
This is an automat
satishd commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1298029817
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -696,11 +704,327 @@ public void run() {
}
}
+public void handleLogSt
satishd commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1298027732
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -696,11 +704,327 @@ public void run() {
}
}
+public void handleLogSt
[
https://issues.apache.org/jira/browse/KAFKA-15354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755805#comment-17755805
]
Sagar Rao commented on KAFKA-15354:
---
[~dengziming], I took a look at this. I believe t
satishd commented on PR #13947:
URL: https://github.com/apache/kafka/pull/13947#issuecomment-1683345956
Failed tests do not seem to be related. @kamalcph Please check and confirm.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
satishd commented on PR #13947:
URL: https://github.com/apache/kafka/pull/13947#issuecomment-1683345343
I will merge the PR to unblock other integration test related PRs. Remaining
items if any can be addressed in followup PRs.
--
This is an automated message from the Apache Git Service.
haodanchen opened a new pull request, #14241:
URL: https://github.com/apache/kafka/pull/14241
- First, the purpose of the heart-beat thread's `maybeLeave` is to help
"fail-fast", so we do our bust not to block it. And if the consumer thread
release lock, and heart-beat thread modifies `gene
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1297944016
##
metadata/src/main/java/org/apache/kafka/image/DelegationTokenDelta.java:
##
@@ -0,0 +1,101 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
haodanchen closed pull request #14240: Update AbstractCoordinator.java
URL: https://github.com/apache/kafka/pull/14240
--
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 unsubs
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1297930601
##
metadata/src/main/java/org/apache/kafka/controller/DelegationTokenControlManager.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (A
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1297918868
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -2999,7 +2999,38 @@ class KafkaApis(val requestChannel: RequestChannel,
}
def handleCreateTokenRe
[
https://issues.apache.org/jira/browse/KAFKA-15345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio resolved KAFKA-15345.
Resolution: Fixed
> KRaft leader should notify the listener only w
haodanchen opened a new pull request, #14240:
URL: https://github.com/apache/kafka/pull/14240
Remove synchronized to improve performance.
1. Use the **_state_** directory may help fast fail, because it is the newly
value.
2. Without **_state_** snapshot, just need **_generation_** snap
jsancio merged PR #14213:
URL: https://github.com/apache/kafka/pull/14213
--
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.
jsancio commented on PR #14213:
URL: https://github.com/apache/kafka/pull/14213#issuecomment-1683208168
Unable to reproduce the test failures locally.
--
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
satishd commented on code in PR #13947:
URL: https://github.com/apache/kafka/pull/13947#discussion_r1297876409
##
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java:
##
@@ -166,6 +166,10 @@ public Cache internalCache() {
return internalCa
vincent81jiang opened a new pull request, #14239:
URL: https://github.com/apache/kafka/pull/14239
When running in kraft mode, LogManager.startup is called in a different
thread than the main broker
startup thread (by BrokerMetadataPublisher when the first metadata update is
received.) If
kamalcph opened a new pull request, #14238:
URL: https://github.com/apache/kafka/pull/14238
To migrate the existing topics to remote log storage, we have to handle the
dynamic topic-level config update to enable remote log storage.
*More detailed description of your change,
if nece
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1297648037
##
metadata/src/main/java/org/apache/kafka/controller/DelegationTokenControlManager.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (A
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1297647792
##
metadata/src/main/java/org/apache/kafka/controller/DelegationTokenControlManager.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (A
kamalcph commented on PR #13947:
URL: https://github.com/apache/kafka/pull/13947#issuecomment-1682800792
@junrao
Test failures are unrelated to this PR. I've ran them locally, they were
succeeded:
```
Build / JDK 11 and Scala 2.13 / [2] tlsProtocol=TLSv1.2, useInlinePem=true –
[
https://issues.apache.org/jira/browse/KAFKA-15375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vincent Jiang reassigned KAFKA-15375:
-
Assignee: Vincent Jiang
> When running in KRaft mode, LogManager may creates CleanShutd
[
https://issues.apache.org/jira/browse/KAFKA-15375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vincent Jiang updated KAFKA-15375:
--
Description:
Consider following sequence when running Kafka in KRaft mode:
# A partition log
[
https://issues.apache.org/jira/browse/KAFKA-15375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vincent Jiang updated KAFKA-15375:
--
Description:
Consider following sequence when running Kafka in KRaft mode:
# A partition log
Vincent Jiang created KAFKA-15375:
-
Summary: When running in KRaft mode, LogManager may creates
CleanShutdown file by mistake
Key: KAFKA-15375
URL: https://issues.apache.org/jira/browse/KAFKA-15375
P
junrao commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1297576757
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -2173,6 +2230,14 @@ object UnifiedLog extends Logging {
}
}
+ private[log] def localRetentionMs(confi
C0urante merged PR #14234:
URL: https://github.com/apache/kafka/pull/14234
--
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
[
https://issues.apache.org/jira/browse/KAFKA-15102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-15102:
--
Fix Version/s: 3.3.3
(was: 3.3)
> Mirror Maker 2 - KIP690 backward comp
C0urante merged PR #14220:
URL: https://github.com/apache/kafka/pull/14220
--
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
[
https://issues.apache.org/jira/browse/KAFKA-15227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755658#comment-17755658
]
Greg Harris commented on KAFKA-15227:
-
We can delay this for some time, as the perfo
[
https://issues.apache.org/jira/browse/KAFKA-15227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris reassigned KAFKA-15227:
---
Assignee: (was: Greg Harris)
> Use plugin.discovery=SERVICE_LOAD in all plugin test sui
mjsax commented on PR #14225:
URL: https://github.com/apache/kafka/pull/14225#issuecomment-1682721943
Thanks for the fix @lucasbru! -- Merged to `trunk`.
--
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
mjsax merged PR #14225:
URL: https://github.com/apache/kafka/pull/14225
--
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-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755598#comment-17755598
]
Dave Wichers edited comment on KAFKA-14206 at 8/17/23 5:36 PM:
---
cmccabe commented on code in PR #14208:
URL: https://github.com/apache/kafka/pull/14208#discussion_r1297536422
##
metadata/src/main/java/org/apache/kafka/controller/ActivationRecordsGenerator.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
cmccabe commented on code in PR #14208:
URL: https://github.com/apache/kafka/pull/14208#discussion_r1297536422
##
metadata/src/main/java/org/apache/kafka/controller/ActivationRecordsGenerator.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
cmccabe commented on code in PR #14208:
URL: https://github.com/apache/kafka/pull/14208#discussion_r1297533375
##
metadata/src/main/java/org/apache/kafka/controller/ActivationRecordsGenerator.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
cmccabe commented on code in PR #14208:
URL: https://github.com/apache/kafka/pull/14208#discussion_r1297531045
##
metadata/src/main/java/org/apache/kafka/controller/ActivationRecordsGenerator.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
cmccabe commented on code in PR #14208:
URL: https://github.com/apache/kafka/pull/14208#discussion_r1297529651
##
metadata/src/main/java/org/apache/kafka/controller/ActivationRecordsGenerator.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
cmccabe commented on code in PR #14208:
URL: https://github.com/apache/kafka/pull/14208#discussion_r1297529002
##
metadata/src/main/java/org/apache/kafka/controller/ActivationRecordsGenerator.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
[
https://issues.apache.org/jira/browse/KAFKA-15353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755648#comment-17755648
]
Calvin Liu commented on KAFKA-15353:
Opened a PR https://github.com/apache/kafka/pul
mumrah opened a new pull request, #14237:
URL: https://github.com/apache/kafka/pull/14237
(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-mai
[
https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755647#comment-17755647
]
Greg Harris commented on KAFKA-15372:
-
[~durban] I should clarify, I believe the beh
cmccabe commented on code in PR #14208:
URL: https://github.com/apache/kafka/pull/14208#discussion_r1297526521
##
metadata/src/main/java/org/apache/kafka/controller/ActivationRecordsGenerator.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
cmccabe commented on code in PR #14208:
URL: https://github.com/apache/kafka/pull/14208#discussion_r1297525659
##
metadata/src/main/java/org/apache/kafka/controller/ActivationRecordsGenerator.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
CalvinConfluent opened a new pull request, #14236:
URL: https://github.com/apache/kafka/pull/14236
As described in https://issues.apache.org/jira/browse/KAFKA-15353
When the AlterPartitionRequest version is < 3 and its builder.build is
called multiple times, both newIsrWithEpochs and newI
cmccabe commented on code in PR #14208:
URL: https://github.com/apache/kafka/pull/14208#discussion_r1297521425
##
metadata/src/main/java/org/apache/kafka/controller/ActivationRecordsGenerator.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
cmccabe commented on code in PR #14208:
URL: https://github.com/apache/kafka/pull/14208#discussion_r1297521425
##
metadata/src/main/java/org/apache/kafka/controller/ActivationRecordsGenerator.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
[
https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755643#comment-17755643
]
Daniel Urban commented on KAFKA-15372:
--
Hi [~gharris1727], I don't have a determini
David Arthur created KAFKA-15374:
Summary: ZK migration fails on configs for default broker resource
Key: KAFKA-15374
URL: https://issues.apache.org/jira/browse/KAFKA-15374
Project: Kafka
Iss
[
https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755629#comment-17755629
]
Greg Harris commented on KAFKA-15372:
-
Hi [~durban] Thanks for the bug report.
Is t
hachikuji commented on code in PR #14213:
URL: https://github.com/apache/kafka/pull/14213#discussion_r1297486408
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -2656,6 +2656,12 @@ private void maybeFireLeaderChange(LeaderAndEpoch
leaderAndEpoch, long ep
OmniaGM commented on code in PR #13201:
URL: https://github.com/apache/kafka/pull/13201#discussion_r1297480256
##
tools/src/main/java/org/apache/kafka/tools/TopicCommand.java:
##
@@ -0,0 +1,1019 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * co
jsancio commented on code in PR #14213:
URL: https://github.com/apache/kafka/pull/14213#discussion_r1297478419
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -2653,11 +2652,11 @@ private boolean shouldFireLeaderChange(LeaderAndEpoch
leaderAndEpoch) {
jsancio commented on code in PR #14213:
URL: https://github.com/apache/kafka/pull/14213#discussion_r1297478095
##
raft/src/main/java/org/apache/kafka/raft/internals/RecordsBatchReader.java:
##
@@ -117,14 +117,8 @@ private void ensureOpen() {
}
private Optional> nextB
OmniaGM commented on code in PR #13201:
URL: https://github.com/apache/kafka/pull/13201#discussion_r1297477323
##
tools/src/main/java/org/apache/kafka/tools/TopicCommand.java:
##
@@ -0,0 +1,1019 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * co
OmniaGM commented on code in PR #13201:
URL: https://github.com/apache/kafka/pull/13201#discussion_r1297476982
##
tools/src/main/java/org/apache/kafka/tools/TopicCommand.java:
##
@@ -0,0 +1,1019 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * co
OmniaGM commented on code in PR #13201:
URL: https://github.com/apache/kafka/pull/13201#discussion_r1297476446
##
tools/src/main/java/org/apache/kafka/tools/TopicCommand.java:
##
@@ -0,0 +1,1019 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * co
OmniaGM commented on code in PR #13201:
URL: https://github.com/apache/kafka/pull/13201#discussion_r1297476207
##
tools/src/main/java/org/apache/kafka/tools/TopicCommand.java:
##
@@ -0,0 +1,1019 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * co
OmniaGM commented on code in PR #13201:
URL: https://github.com/apache/kafka/pull/13201#discussion_r1297475863
##
tools/src/main/java/org/apache/kafka/tools/TopicCommand.java:
##
@@ -0,0 +1,1019 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * co
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1297472470
##
metadata/src/test/java/org/apache/kafka/image/DelegationTokenImageTest.java:
##
@@ -0,0 +1,141 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1297471447
##
metadata/src/main/java/org/apache/kafka/metadata/DelegationTokenData.java:
##
Review Comment:
TokenInformation is Legacy so I'm not updating a test for it.
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1297470130
##
metadata/src/main/java/org/apache/kafka/metadata/DelegationTokenData.java:
##
Review Comment:
I have added a DelegationTokenDataTest.
--
This is an auto
clolov commented on code in PR #14161:
URL: https://github.com/apache/kafka/pull/14161#discussion_r1297412799
##
core/src/main/scala/kafka/server/ConfigHandler.scala:
##
@@ -62,6 +62,12 @@ class TopicConfigHandler(private val logManager: LogManager,
kafkaConfig: KafkaC
top
C0urante commented on code in PR #14230:
URL: https://github.com/apache/kafka/pull/14230#discussion_r1297376126
##
tests/kafkatest/directory_layout/kafka_path.py:
##
@@ -41,14 +41,20 @@
CORE_DEPENDANT_TEST_LIBS_JAR_NAME = "core-dependant-testlibs"
TOOLS_JAR_NAME = "tools"
TOO
[
https://issues.apache.org/jira/browse/KAFKA-15353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Calvin Liu reassigned KAFKA-15353:
--
Assignee: Calvin Liu
> Empty ISR returned from controller after AlterPartition request
>
[
https://issues.apache.org/jira/browse/KAFKA-15353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755614#comment-17755614
]
Calvin Liu commented on KAFKA-15353:
Hey [~showuon], thanks for pointing it out! Wil
clolov commented on code in PR #14161:
URL: https://github.com/apache/kafka/pull/14161#discussion_r1297412799
##
core/src/main/scala/kafka/server/ConfigHandler.scala:
##
@@ -62,6 +62,12 @@ class TopicConfigHandler(private val logManager: LogManager,
kafkaConfig: KafkaC
top
[
https://issues.apache.org/jira/browse/KAFKA-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755598#comment-17755598
]
Dave Wichers edited comment on KAFKA-14206 at 8/17/23 3:46 PM:
---
clolov commented on code in PR #14161:
URL: https://github.com/apache/kafka/pull/14161#discussion_r1297412799
##
core/src/main/scala/kafka/server/ConfigHandler.scala:
##
@@ -62,6 +62,12 @@ class TopicConfigHandler(private val logManager: LogManager,
kafkaConfig: KafkaC
top
Michael Edgar created KAFKA-15373:
-
Summary: AdminClient#describeTopics should not throw
InvalidTopicException if topic ID is not found
Key: KAFKA-15373
URL: https://issues.apache.org/jira/browse/KAFKA-15373
Daniel Urban created KAFKA-15372:
Summary: MM2 rolling restart can drop configuration changes
silently
Key: KAFKA-15372
URL: https://issues.apache.org/jira/browse/KAFKA-15372
Project: Kafka
rondagostino commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1297350659
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -215,9 +215,9 @@ class KafkaApis(val requestChannel: RequestChannel,
case ApiKeys.DESCRIBE_LOG_
C0urante commented on code in PR #14220:
URL: https://github.com/apache/kafka/pull/14220#discussion_r1297349746
##
docs/upgrade.html:
##
@@ -43,6 +43,10 @@ Notable changes in 3
See https://cwiki.apache.org/confluence/display/KAFKA/KIP-925%3A+Rack+aware+task+assignme
C0urante commented on PR #14220:
URL: https://github.com/apache/kafka/pull/14220#issuecomment-1682432780
> I was thinking that in addition to this upgrade note, we would also need
to backport the configuration documentation to keep the links valid, and
because the documentation would be inc
C0urante opened a new pull request, #14235:
URL: https://github.com/apache/kafka/pull/14235
Backports the changes from https://github.com/apache/kafka/pull/14220 onto
3.5. Since we do not have autogenerated configuration docs for MM2 on 3.5 and
older branches, information on the property (a
lucasbru commented on PR #14225:
URL: https://github.com/apache/kafka/pull/14225#issuecomment-1682378421
Test failures are unrelated
--
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 c
C0urante closed pull request #14233: MINOR: Permit tombstone offsets with any
partition for file source connector
URL: https://github.com/apache/kafka/pull/14233
--
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
C0urante commented on PR #14233:
URL: https://github.com/apache/kafka/pull/14233#issuecomment-1682364193
Closing in favor of https://github.com/apache/kafka/pull/14234
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
yashmayya commented on PR #14234:
URL: https://github.com/apache/kafka/pull/14234#issuecomment-1682363708
Ah whoops, I missed that, my bad!
--
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 spe
C0urante commented on PR #14234:
URL: https://github.com/apache/kafka/pull/14234#issuecomment-1682361707
@yashmayya Beat you to it :)
https://github.com/apache/kafka/pull/14233
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
yashmayya commented on PR #14234:
URL: https://github.com/apache/kafka/pull/14234#issuecomment-1682360405
@C0urante now that https://github.com/apache/kafka/pull/14005 has been
merged, could you please take a look at this minor change to
`FileStreamSourceConnector::alterOffsets` (based on t
yashmayya opened a new pull request, #14234:
URL: https://github.com/apache/kafka/pull/14234
- Background -
https://cwiki.apache.org/confluence/display/KAFKA/KIP-875%3A+First-class+offsets+support+in+Kafka+Connect,
https://github.com/apache/kafka/pull/13945#discussion_r1266867639,
https://
C0urante opened a new pull request, #14233:
URL: https://github.com/apache/kafka/pull/14233
This aligns the behavior of the file and MM2 source connectors with regards
to tombstone offsets submitted via the REST API. Partition validation is
intentionally disabled for tombstone offsets to al
C0urante merged PR #14005:
URL: https://github.com/apache/kafka/pull/14005
--
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
OmniaGM commented on PR #13204:
URL: https://github.com/apache/kafka/pull/13204#issuecomment-1682276851
The test is failing because of an unrelated package `:storage:test` with JDK
11 and Scala 2.13.
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/KAFKA-8128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755543#comment-17755543
]
Gabor Somogyi commented on KAFKA-8128:
--
Sounds great.
> Dynamic JAAS change for cli
riedelmax commented on PR #14124:
URL: https://github.com/apache/kafka/pull/14124#issuecomment-1682236535
Right now the method does almost nothing.. I could strip it down to this
version, which is enough to make tests pass:
```
def handleConsumerGroupDescribe(request: RequestChannel.R
clolov commented on PR #14116:
URL: https://github.com/apache/kafka/pull/14116#issuecomment-1682210532
Huh, yeah, no idea. I have been trying to replicate it locally and it
appears to be doing exactly what you would expect it to.
--
This is an automated message from the Apache Git Service
clolov commented on PR #14116:
URL: https://github.com/apache/kafka/pull/14116#issuecomment-1682078236
Heya @kamalcph! I have seen this error pop up when server.shutdown hasn't
been called in integration tests, I would suggest looking into whether for
whatever reason there is something whic
kamalcph commented on PR #14116:
URL: https://github.com/apache/kafka/pull/14116#issuecomment-1682062995
How to fix the below error in the test? The test is currently marked as
DISABLED but still fails with below error, there are some left-over threads:
Build / JDK 11 and Scala 2.13 /
[
https://issues.apache.org/jira/browse/KAFKA-14589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755426#comment-17755426
]
Omnia Ibrahim commented on KAFKA-14589:
---
[~nizhikov] sure
> Move ConsumerGroupCom
[
https://issues.apache.org/jira/browse/KAFKA-14588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim reassigned KAFKA-14588:
-
Assignee: Nikolay Izhikov (was: Omnia Ibrahim)
> Move ConfigCommand to tools
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755425#comment-17755425
]
Omnia Ibrahim commented on KAFKA-14588:
---
[~nizhikov] sure go ahead as am focusing
1 - 100 of 104 matches
Mail list logo
