DengShuaiSimon opened a new pull request, #13730:
URL: https://github.com/apache/kafka/pull/13730
*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
vamossagar12 commented on PR #13726:
URL: https://github.com/apache/kafka/pull/13726#issuecomment-1552416862
Test failures seem unrelated. Couple of failing connect related tests are
being fixed via separate JIRA tickets
--
This is an automated message from the Apache Git Service.
To
aaron-ai commented on PR #13710:
URL: https://github.com/apache/kafka/pull/13710#issuecomment-1552382217
@jlprat @showuon @C0urante @dajac Could you please take a look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/KAFKA-14833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
HaiyuanZhao reassigned KAFKA-14833:
---
Assignee: HaiyuanZhao
> ZK migration cannot start if a ZK controller was not previously
[
https://issues.apache.org/jira/browse/KAFKA-14846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
HaiyuanZhao reassigned KAFKA-14846:
---
Assignee: HaiyuanZhao
> Fix overly large record batches in ZkMigrationClient
>
[
https://issues.apache.org/jira/browse/KAFKA-14939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
HaiyuanZhao reassigned KAFKA-14939:
---
Assignee: HaiyuanZhao
> Only expose ZkMigrationState metric if metadata.version supports
satishd merged PR #13535:
URL: https://github.com/apache/kafka/pull/13535
--
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:
AmareshB commented on code in PR #6247:
URL: https://github.com/apache/kafka/pull/6247#discussion_r1197203647
##
clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java:
##
@@ -388,6 +388,48 @@ public AlterConfigsResult alterConfigs(Map configs) {
*/
AmareshB commented on code in PR #6247:
URL: https://github.com/apache/kafka/pull/6247#discussion_r1197203647
##
clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java:
##
@@ -388,6 +388,48 @@ public AlterConfigsResult alterConfigs(Map configs) {
*/
artemlivshits commented on code in PR #13608:
URL: https://github.com/apache/kafka/pull/13608#discussion_r1197145142
##
storage/src/main/java/org/apache/kafka/storage/internals/log/ProducerStateEntry.java:
##
@@ -41,18 +42,35 @@ public class ProducerStateEntry {
private
kirktrue commented on PR #13591:
URL: https://github.com/apache/kafka/pull/13591#issuecomment-1552142480
>
[ea81e99](https://github.com/apache/kafka/commit/ea81e99e5980c807414651034a8c60426a158ca4)
added TransitionToUninitialized. Can we confirm this has the behavior we
expect? I believe
[
https://issues.apache.org/jira/browse/KAFKA-14970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Proven Provenzano updated KAFKA-14970:
--
Fix Version/s: 3.5.0
> Dual write mode testing for SCRAM and Quota
>
pprovenzano opened a new pull request, #13729:
URL: https://github.com/apache/kafka/pull/13729
Add two tests for dual write mode for ZK to KRaft migration.
These test updating SCRAM records while in dual write mode and validate that
the records are written to ZK.
Fixed a bug
JimGalasyn commented on PR #13728:
URL: https://github.com/apache/kafka/pull/13728#issuecomment-1551916913
cc @mjsax
--
This is an automated message from the Apache Git Service.
To
Christopher Auston created KAFKA-15006:
--
Summary: kafka-get-offsets.sh returns 0 for earliest offset on a
compacted topic
Key: KAFKA-15006
URL: https://issues.apache.org/jira/browse/KAFKA-15006
satishd commented on PR #13535:
URL: https://github.com/apache/kafka/pull/13535#issuecomment-1551837017
Thanks @junrao for the latest comments, addressed them with the latest
commit.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
philipnee commented on PR #13678:
URL: https://github.com/apache/kafka/pull/13678#issuecomment-1551778364
@erikvanoosten - Thanks for following up on this PR, I think we are really
closed here. Also apologize about the misleading comment. I left a few
comments above.
--
This is an
cmccabe commented on PR #13727:
URL: https://github.com/apache/kafka/pull/13727#issuecomment-1551766740
merged, thanks
--
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
cmccabe closed pull request #13727: MINOR: Rename handleSnapshot to
handleLoadSnapshot
URL: https://github.com/apache/kafka/pull/13727
--
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
philipnee commented on code in PR #13678:
URL: https://github.com/apache/kafka/pull/13678#discussion_r1196816858
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java:
##
@@ -668,6 +695,7 @@ public void onFailure(RuntimeException e,
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-15005:
Description:
Our MM2 is running version 2.5.1.
After a rebalance of our MM2 source tasks, we found there
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-15005:
Description:
Our MM2 is running version 2.5.1.
After a rebalance of our MM2 source tasks, we found there
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-15005:
Description:
After a rebalance of our MM2 source tasks, we found there were several tasks
always in
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-15005:
Description:
After a rebalance of our MM2 source tasks, we found there were several tasks
always in
Yu Wang created KAFKA-15005:
---
Summary: Status of KafkaConnect task not correct
Key: KAFKA-15005
URL: https://issues.apache.org/jira/browse/KAFKA-15005
Project: Kafka
Issue Type: Bug
splett2 opened a new pull request, #13727:
URL: https://github.com/apache/kafka/pull/13727
This PR tries to make it explicit that `handleSnapshot` is handling the
loading of a snapshot. To someone who is not familiar with the code or KRaft's
design, `handleSnapshot` may sound like the
junrao commented on code in PR #13535:
URL: https://github.com/apache/kafka/pull/13535#discussion_r1196786120
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -1175,49 +1260,78 @@ class ReplicaManager(val config: KafkaConfig,
fetchPartitionStatus +=
Akhilesh Chaganti created KAFKA-15004:
-
Summary: Topic config changes are not synced during zk to kraft
migration (dual-write)
Key: KAFKA-15004
URL: https://issues.apache.org/jira/browse/KAFKA-15004
Akhilesh Chaganti created KAFKA-15003:
-
Summary: TopicIdReplicaAssignment is not updated in migration
(dual-write) when partitions are changed for topic
Key: KAFKA-15003
URL:
Arushi Rai created KAFKA-15002:
--
Summary: Moderate vulnerability in org.bitbucket.b_c_jose4j
Key: KAFKA-15002
URL: https://issues.apache.org/jira/browse/KAFKA-15002
Project: Kafka
Issue Type:
Arushi Rai created KAFKA-15001:
--
Summary: Medium vulnerabilities in Jetty
Key: KAFKA-15001
URL: https://issues.apache.org/jira/browse/KAFKA-15001
Project: Kafka
Issue Type: Task
Affects
[
https://issues.apache.org/jira/browse/KAFKA-15000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723502#comment-17723502
]
Manyanda Chitimbo commented on KAFKA-15000:
---
Hi [~arushir] I've no idea but let me tag along
[
https://issues.apache.org/jira/browse/KAFKA-15000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723489#comment-17723489
]
Arushi Rai commented on KAFKA-15000:
Hi [~manyanda]
Thank you for the response.
I do not see
[
https://issues.apache.org/jira/browse/KAFKA-15000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723486#comment-17723486
]
Manyanda Chitimbo commented on KAFKA-15000:
---
The PR
Arushi Rai created KAFKA-15000:
--
Summary: High vulnerability PRISMA-2023-0067 reported in
jackson-core
Key: KAFKA-15000
URL: https://issues.apache.org/jira/browse/KAFKA-15000
Project: Kafka
dengziming commented on code in PR #13562:
URL: https://github.com/apache/kafka/pull/13562#discussion_r1196474288
##
tools/src/test/java/org/apache/kafka/tools/GetOffsetShellTest.java:
##
@@ -0,0 +1,160 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
satishd merged PR #13718:
URL: https://github.com/apache/kafka/pull/13718
--
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-12384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana reopened KAFKA-12384:
> Flaky Test ListOffsetsRequestTest.testResponseIncludesLeaderEpoch
>
[
https://issues.apache.org/jira/browse/KAFKA-12384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723454#comment-17723454
]
Satish Duggana commented on KAFKA-12384:
Reopening as these tests are still flaky and failing in
hudeqi commented on PR #13696:
URL: https://github.com/apache/kafka/pull/13696#issuecomment-1551312847
hi, do you have time to review this issue？ @showuon
--
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
vamossagar12 opened a new pull request, #13726:
URL: https://github.com/apache/kafka/pull/13726
AbstractWorkerSourceTask is not enforcing the errors.retry.timeout and
errors.retry.delay.max.ms parameters in case of a RetriableException during
task.poll(). [KIP-298
hudeqi commented on PR #13719:
URL: https://github.com/apache/kafka/pull/13719#issuecomment-1551304423
Hi, do you have time to help review this? @dajac @satishd
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/KAFKA-14999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sheriff updated KAFKA-14999:
Description:
Three kafka brokers system (three VMs and each VM contains one kafka broker).
One of the
satishd commented on PR #13535:
URL: https://github.com/apache/kafka/pull/13535#issuecomment-1551099626
Thanks @junrao for the updated review. Addressed your latest minor review
comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/KAFKA-14999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sheriff updated KAFKA-14999:
Description:
Three kafka brokers system (three VMs and each VM contains one kafka broker).
One of the
Sheriff created KAFKA-14999:
---
Summary: Kafka Clients not able to publish message when one of
broker is shut downed
Key: KAFKA-14999
URL: https://issues.apache.org/jira/browse/KAFKA-14999
Project: Kafka
jlprat commented on code in PR #13723:
URL: https://github.com/apache/kafka/pull/13723#discussion_r1196222089
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorConfigTest.java:
##
@@ -43,7 +43,8 @@ protected TestMirrorConnectorConfig(Map
props) {
erikvanoosten commented on code in PR #13678:
URL: https://github.com/apache/kafka/pull/13678#discussion_r1196205881
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java:
##
@@ -1223,6 +1233,26 @@ public void
erikvanoosten commented on code in PR #13678:
URL: https://github.com/apache/kafka/pull/13678#discussion_r1196205881
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java:
##
@@ -1223,6 +1233,26 @@ public void
hudeqi commented on code in PR #13719:
URL: https://github.com/apache/kafka/pull/13719#discussion_r1196003399
##
core/src/main/scala/kafka/server/AbstractFetcherThread.scala:
##
@@ -680,12 +680,15 @@ abstract class AbstractFetcherThread(name: String,
*/
val
50 matches
Mail list logo
