wcarlson5 opened a new pull request, #14247:
URL: https://github.com/apache/kafka/pull/14247
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of
wcarlson5 commented on PR #14027:
URL: https://github.com/apache/kafka/pull/14027#issuecomment-1684718224
No tests failled
--
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.
wcarlson5 merged PR #14027:
URL: https://github.com/apache/kafka/pull/14027
--
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:
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1299014422
##
core/src/main/scala/kafka/server/ControllerApis.scala:
##
@@ -842,6 +848,114 @@ class ControllerApis(val requestChannel: RequestChannel,
}
}
+ def
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1299014398
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -6069,19 +6071,19 @@ class KafkaApisTest {
@Test
def
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1299014357
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -5290,8 +5290,10 @@ class KafkaApisTest {
// read the header from the buffer first so
David Arthur created KAFKA-15381:
Summary: Controller waiting for migration should only allow
failover when transactions are supported
Key: KAFKA-15381
URL: https://issues.apache.org/jira/browse/KAFKA-15381
mumrah commented on code in PR #14208:
URL: https://github.com/apache/kafka/pull/14208#discussion_r1298915833
##
metadata/src/main/java/org/apache/kafka/controller/ActivationRecordsGenerator.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
wcarlson5 closed pull request #13641: KAFKA-14936: Add Grace Period to Stream
Table Join
URL: https://github.com/apache/kafka/pull/13641
--
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
Justine Olshan created KAFKA-15380:
--
Summary: Try complete actions after callback
Key: KAFKA-15380
URL: https://issues.apache.org/jira/browse/KAFKA-15380
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-14627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-14627.
-
Resolution: Fixed
> Modernize Connect plugin discovery
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-15226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-15226.
-
Fix Version/s: 3.6.0
Resolution: Fixed
> System tests for plugin.discovery worker
gharris1727 commented on PR #14230:
URL: https://github.com/apache/kafka/pull/14230#issuecomment-1684494668
Test failures in CI appear unrelated.
All of the Connect system tests passed for me locally.
--
This is an automated message from the Apache Git Service.
To respond to the
splett2 opened a new pull request, #14246:
URL: https://github.com/apache/kafka/pull/14246
### What
Noticed that there was a dangling unused class (LongRef, replaced by
PrimitiveRef.LongRef), and the LogOffsetMetadata toString was a little oddly
formatted.
*Summary of testing
jolshan commented on PR #14197:
URL: https://github.com/apache/kafka/pull/14197#issuecomment-1684439722
I recommend turning off whitespace changes so that the diff renders
correctly.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
cmccabe commented on code in PR #14208:
URL: https://github.com/apache/kafka/pull/14208#discussion_r1298865134
##
metadata/src/main/java/org/apache/kafka/controller/ActivationRecordsGenerator.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
mumrah commented on code in PR #14122:
URL: https://github.com/apache/kafka/pull/14122#discussion_r1298845661
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -9119,4 +8742,257 @@ public void
wcarlson5 commented on code in PR #14027:
URL: https://github.com/apache/kafka/pull/14027#discussion_r1298818523
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java:
##
@@ -1271,7 +1271,7 @@ private KStream doStreamTableJoin(final
KTable
[
https://issues.apache.org/jira/browse/KAFKA-15379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-15379:
---
Priority: Minor (was: Major)
> Add option for Grace period Joins to disable changelog
[
https://issues.apache.org/jira/browse/KAFKA-15379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-15379:
---
Component/s: streams
> Add option for Grace period Joins to disable changelog creation
>
[
https://issues.apache.org/jira/browse/KAFKA-15379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-15379:
---
Affects Version/s: 3.6.0
> Add option for Grace period Joins to disable changelog creation
[
https://issues.apache.org/jira/browse/KAFKA-15379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-15379:
---
Labels: kip (was: )
> Add option for Grace period Joins to disable changelog creation
>
Walker Carlson created KAFKA-15379:
--
Summary: Add option for Grace period Joins to disable changelog
creation
Key: KAFKA-15379
URL: https://issues.apache.org/jira/browse/KAFKA-15379
Project: Kafka
bbejeck commented on code in PR #14027:
URL: https://github.com/apache/kafka/pull/14027#discussion_r1298812512
##
streams/src/test/java/org/apache/kafka/streams/integration/JoinGracePeriodDurabilityIntegrationTest.java:
##
@@ -0,0 +1,275 @@
+/*
+ * Licensed to the Apache
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298798195
##
core/src/main/scala/kafka/server/BrokerServer.scala:
##
@@ -279,10 +280,7 @@ class BrokerServer(
)
/* start token manager */
- if
bbejeck commented on code in PR #14027:
URL: https://github.com/apache/kafka/pull/14027#discussion_r1298789285
##
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBuffer.java:
##
@@ -45,17 +53,24 @@ public class
mjsax commented on code in PR #14027:
URL: https://github.com/apache/kafka/pull/14027#discussion_r1298793261
##
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBytesStore.java:
##
@@ -42,7 +46,29 @@ protected KeyValue
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298784076
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -6069,19 +6071,19 @@ class KafkaApisTest {
@Test
def
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298770601
##
core/src/main/scala/kafka/server/ControllerApis.scala:
##
@@ -842,6 +848,114 @@ class ControllerApis(val requestChannel: RequestChannel,
}
}
+ def
rondagostino commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298761957
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -5290,8 +5290,10 @@ class KafkaApisTest {
// read the header from the buffer first so
rondagostino commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298759956
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -6069,19 +6071,19 @@ class KafkaApisTest {
@Test
def
rondagostino commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298748051
##
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsTest.scala:
##
@@ -109,13 +127,44 @@ class DelegationTokenRequestsTest extends BaseRequestTest
rondagostino commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298740130
##
core/src/main/scala/kafka/server/BrokerServer.scala:
##
@@ -279,10 +280,7 @@ class BrokerServer(
)
/* start token manager */
- if
rondagostino commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298734803
##
core/src/main/scala/kafka/server/ControllerApis.scala:
##
@@ -842,6 +848,114 @@ class ControllerApis(val requestChannel: RequestChannel,
}
}
+ def
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298728194
##
core/src/main/scala/kafka/server/DelegationTokenManager.scala:
##
@@ -165,16 +99,16 @@ object DelegationTokenManager {
class DelegationTokenManager(val
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298721551
##
metadata/src/main/java/org/apache/kafka/controller/DelegationTokenControlManager.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/KAFKA-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15378:
Component/s: system tests
> Rolling upgrade system tests are failing
>
rondagostino commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298718349
##
core/src/main/scala/kafka/server/DelegationTokenManager.scala:
##
@@ -165,16 +99,16 @@ object DelegationTokenManager {
class DelegationTokenManager(val
florin-akermann commented on PR #14174:
URL: https://github.com/apache/kafka/pull/14174#issuecomment-1684251499
@mjsax @guozhangwang I'd say this PR is ready to be reviewd. May I ask for
your input or do you know who to poke?
--
This is an automated message from the Apache Git Service.
mumrah commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298714610
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -2999,7 +2999,38 @@ class KafkaApis(val requestChannel: RequestChannel,
}
def
rondagostino commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298706120
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -2999,7 +2999,38 @@ class KafkaApis(val requestChannel: RequestChannel,
}
def
rondagostino commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298687894
##
metadata/src/main/java/org/apache/kafka/controller/DelegationTokenControlManager.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation
rondagostino commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298683576
##
metadata/src/main/java/org/apache/kafka/controller/DelegationTokenControlManager.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation
rondagostino commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298682884
##
metadata/src/main/java/org/apache/kafka/controller/DelegationTokenControlManager.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/KAFKA-15374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-15374:
-
Fix Version/s: (was: 3.4.2)
> ZK migration fails on configs for default broker resource
>
[
https://issues.apache.org/jira/browse/KAFKA-15374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-15374:
-
Affects Version/s: (was: 3.4.1)
> ZK migration fails on configs for default broker resource
[
https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756062#comment-17756062
]
Greg Harris commented on KAFKA-15372:
-
Here's a proof-of-concept for the fix:
gharris1727 opened a new pull request, #14245:
URL: https://github.com/apache/kafka/pull/14245
This is an extremely sloppy proof-of-concept and should not be merged in
it's current state, as it breaks a lot of abstractions. This is meant only for
diagnostic purposes.
### Committer
mumrah merged PR #14237:
URL: https://github.com/apache/kafka/pull/14237
--
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:
mumrah commented on PR #14237:
URL: https://github.com/apache/kafka/pull/14237#issuecomment-1684172655
Test failures look unrelated
https://github.com/apache/kafka/assets/55116/19cfb202-781e-4930-adc1-15485c8574be;>
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756048#comment-17756048
]
Greg Harris edited comment on KAFKA-15372 at 8/18/23 4:38 PM:
--
[~durban]
[
https://issues.apache.org/jira/browse/KAFKA-15319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-15319.
---
Resolution: Fixed
> Upgrade rocksdb to fix CVE-2022-37434
>
cadonna merged PR #14216:
URL: https://github.com/apache/kafka/pull/14216
--
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:
[
https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris updated KAFKA-15372:
Issue Type: Bug (was: Improvement)
> MM2 rolling restart can drop configuration changes silently
[
https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris updated KAFKA-15372:
Fix Version/s: 3.6.0
> MM2 rolling restart can drop configuration changes silently
>
[
https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756048#comment-17756048
]
Greg Harris commented on KAFKA-15372:
-
[~durban] thank you for the sanity check, I see the flaw now.
junrao commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1298640349
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -696,11 +704,327 @@ public void run() {
}
}
+public void
yashmayya opened a new pull request, #14244:
URL: https://github.com/apache/kafka/pull/14244
From https://issues.apache.org/jira/browse/KAFKA-15377:
> The `GET /connectors/{connector}/tasks-config` endpoint added in
clolov commented on code in PR #14161:
URL: https://github.com/apache/kafka/pull/14161#discussion_r1298593281
##
core/src/test/scala/unit/kafka/server/KafkaServerTest.scala:
##
@@ -154,6 +155,96 @@ class KafkaServerTest extends QuorumTestHarness {
server.shutdown()
}
[
https://issues.apache.org/jira/browse/KAFKA-14589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikolay Izhikov reassigned KAFKA-14589:
---
Assignee: Nikolay Izhikov (was: Omnia Ibrahim)
> Move ConsumerGroupCommand to
mumrah commented on code in PR #14208:
URL: https://github.com/apache/kafka/pull/14208#discussion_r1298547454
##
metadata/src/main/java/org/apache/kafka/controller/ActivationRecordsGenerator.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
mumrah commented on code in PR #14208:
URL: https://github.com/apache/kafka/pull/14208#discussion_r1298547454
##
metadata/src/main/java/org/apache/kafka/controller/ActivationRecordsGenerator.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
mumrah commented on code in PR #14208:
URL: https://github.com/apache/kafka/pull/14208#discussion_r1298547454
##
metadata/src/main/java/org/apache/kafka/controller/ActivationRecordsGenerator.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
mumrah commented on code in PR #14208:
URL: https://github.com/apache/kafka/pull/14208#discussion_r1298547454
##
metadata/src/main/java/org/apache/kafka/controller/ActivationRecordsGenerator.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/KAFKA-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756002#comment-17756002
]
Lucas Brutschy edited comment on KAFKA-15378 at 8/18/23 2:34 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy updated KAFKA-15378:
---
Description:
The system tests are having failures for these tests:
{noformat}
[
https://issues.apache.org/jira/browse/KAFKA-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756002#comment-17756002
]
Lucas Brutschy commented on KAFKA-15378:
Thanks, [~ChrisEgerton] , I didn't realize that even
[
https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755997#comment-17755997
]
Daniel Urban edited comment on KAFKA-15372 at 8/18/23 2:33 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755997#comment-17755997
]
Daniel Urban commented on KAFKA-15372:
--
[~gharris1727] I have a bit more information: we managed to
[
https://issues.apache.org/jira/browse/KAFKA-15377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755993#comment-17755993
]
Chris Egerton commented on KAFKA-15377:
---
I don't think a KIP is necessary, for the same reasons
[
https://issues.apache.org/jira/browse/KAFKA-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755990#comment-17755990
]
Chris Egerton commented on KAFKA-15378:
---
[~lbrutschy] the
[
https://issues.apache.org/jira/browse/KAFKA-15219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755975#comment-17755975
]
Proven Provenzano commented on KAFKA-15219:
---
We would like to push the PR today, so if you
pprovenzano commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298461774
##
core/src/main/scala/kafka/server/ControllerApis.scala:
##
@@ -842,6 +848,114 @@ class ControllerApis(val requestChannel: RequestChannel,
}
}
+ def
satishd merged PR #13947:
URL: https://github.com/apache/kafka/pull/13947
--
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:
[
https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755904#comment-17755904
]
Haruki Okada edited comment on KAFKA-15046 at 8/18/23 12:05 PM:
I
hudeqi commented on PR #14243:
URL: https://github.com/apache/kafka/pull/14243#issuecomment-1683773061
Hi, @divijvaidya @satishd If you have time, help to review this pr, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
omkreddy commented on code in PR #14083:
URL: https://github.com/apache/kafka/pull/14083#discussion_r1298325937
##
core/src/main/scala/kafka/server/ControllerApis.scala:
##
@@ -842,6 +848,114 @@ class ControllerApis(val requestChannel: RequestChannel,
}
}
+ def
[
https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755904#comment-17755904
]
Haruki Okada commented on KAFKA-15046:
--
I submitted a patch
[
https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-15046:
-
Attachment: image-2023-08-18-19-29-56-377.png
> Produce performance issue under high disk load
[
https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-15046:
-
Attachment: image-2023-08-18-19-23-36-597.png
> Produce performance issue under high disk load
iamgd67 closed pull request #8274: KAFKA-9699: remove -E option from sed in
kafka-run-class.sh
URL: https://github.com/apache/kafka/pull/8274
--
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
iamgd67 commented on PR #8274:
URL: https://github.com/apache/kafka/pull/8274#issuecomment-1683688095
after all these years, old version of `sed` is really rare. Using `-E` will
make the regex expression simpler, so just close this PR.
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755898#comment-17755898
]
Haruki Okada commented on KAFKA-15046:
--
After dug into the fsync call paths in detail, I summarized
Lucas Brutschy created KAFKA-15378:
--
Summary: Rolling upgrade system tests are failing
Key: KAFKA-15378
URL: https://issues.apache.org/jira/browse/KAFKA-15378
Project: Kafka
Issue Type:
lucasbru commented on PR #14216:
URL: https://github.com/apache/kafka/pull/14216#issuecomment-1683538192
The benchmarks are clean:
https://jenkins.confluent.io/job/confluentinc/job/kafka-streams-benchmarks/job/master/655/console
The system tests are having failures:
[
https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755833#comment-17755833
]
Daniel Urban commented on KAFKA-15372:
--
[~gharris1727] Not sure if I follow this part: "should
[
https://issues.apache.org/jira/browse/KAFKA-15377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755826#comment-17755826
]
Yash Mayya edited comment on KAFKA-15377 at 8/18/23 7:13 AM:
-
[~mimaison]
[
https://issues.apache.org/jira/browse/KAFKA-15377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755826#comment-17755826
]
Yash Mayya commented on KAFKA-15377:
[~mimaison] [~ChrisEgerton] even though this does technically
[
https://issues.apache.org/jira/browse/KAFKA-15377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya updated KAFKA-15377:
---
Description: The {{GET /connectors/\{connector}/tasks-config}} endpoint
added in
Yash Mayya created KAFKA-15377:
--
Summary: GET /connectors/{connector}/tasks-config endpoint exposes
externalized secret values
Key: KAFKA-15377
URL: https://issues.apache.org/jira/browse/KAFKA-15377
[
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
[
https://issues.apache.org/jira/browse/KAFKA-15339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755812#comment-17755812
]
Sagar Rao edited comment on KAFKA-15339 at 8/18/23 5:52 AM:
Thanks for
[
https://issues.apache.org/jira/browse/KAFKA-15339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755812#comment-17755812
]
Sagar Rao commented on KAFKA-15339:
---
Thanks for reporting this bug [~functioner]. As you correctly
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
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
95 matches
Mail list logo
