[
https://issues.apache.org/jira/browse/KAFKA-15238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya updated KAFKA-15238:
---
Summary: Connect workers can be disabled by DLQ-related blocking admin
client calls (was: Connect w
Yash Mayya created KAFKA-15238:
--
Summary: Connect workers can be disabled by DLQ related stuck
admin client calls
Key: KAFKA-15238
URL: https://issues.apache.org/jira/browse/KAFKA-15238
Project: Kafka
David Jacot created KAFKA-15237:
---
Summary: Implement `offsets.commit.timeout.ms` setting
Key: KAFKA-15237
URL: https://issues.apache.org/jira/browse/KAFKA-15237
Project: Kafka
Issue Type: Sub-t
fvaleri commented on code in PR #13562:
URL: https://github.com/apache/kafka/pull/13562#discussion_r1271787804
##
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contri
[
https://issues.apache.org/jira/browse/KAFKA-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746199#comment-17746199
]
Luke Chen commented on KAFKA-12283:
---
Thanks [~sagarrao] !
> Flaky Test
> RebalanceSo
[
https://issues.apache.org/jira/browse/KAFKA-10457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746198#comment-17746198
]
Sagar Rao commented on KAFKA-10457:
---
[~yash.mayya], IIRC, you had worked on an issue r
[
https://issues.apache.org/jira/browse/KAFKA-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746197#comment-17746197
]
Sagar Rao edited comment on KAFKA-12283 at 7/24/23 5:02 AM:
[
https://issues.apache.org/jira/browse/KAFKA-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-12283.
---
Resolution: Fixed
> Flaky Test
> RebalanceSourceConnectorsIntegrationTest#testMultipleWorkersRejoin
[
https://issues.apache.org/jira/browse/KAFKA-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746197#comment-17746197
]
Sagar Rao commented on KAFKA-12283:
---
The flakiness with this test was also fixed as pa
[
https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-8391.
--
Resolution: Fixed
Fixed with https://github.com/apache/kafka/pull/12561
> Flaky Test RebalanceSourceCo
[
https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746195#comment-17746195
]
Sagar Rao edited comment on KAFKA-8391 at 7/24/23 5:00 AM:
---
Jus
[
https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746195#comment-17746195
]
Sagar Rao commented on KAFKA-8391:
--
Just bumped upon this. The issue mentioned above
(h
[
https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-8391:
Assignee: Sagar Rao
> Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector
> --
vamossagar12 commented on code in PR #14051:
URL: https://github.com/apache/kafka/pull/14051#discussion_r1271739558
##
core/src/test/scala/unit/kafka/cluster/PartitionTest.scala:
##
@@ -1290,6 +1290,56 @@ class PartitionTest extends AbstractPartitionTest {
)
}
+ @Test
github-actions[bot] commented on PR #13571:
URL: https://github.com/apache/kafka/pull/13571#issuecomment-1647146954
This PR is being marked as stale since it has not had any activity in 90
days. If you would like to keep this PR alive, please ask a committer for
review. If the PR has merge
zhpyc closed pull request #13105: MINOR: fix typo in KafkaConsumer.java
URL: https://github.com/apache/kafka/pull/13105
--
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 unsub
showuon commented on code in PR #14051:
URL: https://github.com/apache/kafka/pull/14051#discussion_r1271666143
##
core/src/test/scala/unit/kafka/cluster/PartitionTest.scala:
##
@@ -1290,6 +1290,56 @@ class PartitionTest extends AbstractPartitionTest {
)
}
+ @Test
+ d
rreddy-22 commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1271665613
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/AssignmentTopicDescriber.java:
##
@@ -0,0 +1,59 @@
+/*
+ * Licensed to the Apache Softw
[
https://issues.apache.org/jira/browse/KAFKA-14712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen resolved KAFKA-14712.
---
Resolution: Fixed
> Confusing error when writing downgraded FeatureImage
> -
showuon merged PR #13773:
URL: https://github.com/apache/kafka/pull/13773
--
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.
showuon commented on PR #13773:
URL: https://github.com/apache/kafka/pull/13773#issuecomment-1647109827
Failed tests are unrelated:
```
Build / JDK 17 and Scala 2.13 /
org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testOffsetTranslationBehind
olalamichelle opened a new pull request, #14078:
URL: https://github.com/apache/kafka/pull/14078
"The test RefreshingHttpsJwksTest#testSecondaryRefreshAfterElapsedDelay
relies on the actual system clock, which makes it frequently fail. The fix adds
a second constructor that allows for passi
vamossagar12 commented on PR #14051:
URL: https://github.com/apache/kafka/pull/14051#issuecomment-1647039846
@showuon as suggested, I added the unit test. Thanks for your help!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
ex172000 closed pull request #14076: MINOR: Use Awaitility for waiting in test
URL: https://github.com/apache/kafka/pull/14076
--
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.
T
[
https://issues.apache.org/jira/browse/KAFKA-15235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746133#comment-17746133
]
Eike Thaden commented on KAFKA-15235:
-
[~bmscomp] thank you preparing this fix! The
ex172000 commented on code in PR #14075:
URL: https://github.com/apache/kafka/pull/14075#discussion_r1271558534
##
build.gradle:
##
@@ -808,10 +809,9 @@ if (userEnableTestCoverage) {
executionData.from = javaProjects.jacocoTestReport.executionData
reports {
- ht
lihaosky commented on code in PR #14030:
URL: https://github.com/apache/kafka/pull/14030#discussion_r1271539596
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java:
##
@@ -185,4 +191,224 @@ public boolean validateClientRack
[
https://issues.apache.org/jira/browse/KAFKA-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746108#comment-17746108
]
Elkhan Eminov commented on KAFKA-14112:
---
[~viktorsomogyi] I've created the PR, ple
elkkhan opened a new pull request, #14077:
URL: https://github.com/apache/kafka/pull/14077
The replication offset lag is the difference of the last end offset of the
source partition (LEO) the last replicated source offset (LRO), +1 (to account
for zero-based offset numbering) The offset l
[
https://issues.apache.org/jira/browse/KAFKA-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elkhan Eminov updated KAFKA-14112:
--
Description:
The replication offset lag is the difference of the {*}l{*}ast {*}e{*}nd
{*}o{*}
[
https://issues.apache.org/jira/browse/KAFKA-15215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746106#comment-17746106
]
Guozhang Wang commented on KAFKA-15215:
---
Just realized I have not read the KIP! :)
[
https://issues.apache.org/jira/browse/KAFKA-15215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746102#comment-17746102
]
Guozhang Wang commented on KAFKA-15215:
---
[~ableegoldman] Thanks for bringing this
ruslankrivoshein commented on code in PR #13562:
URL: https://github.com/apache/kafka/pull/13562#discussion_r1271470073
##
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
ruslankrivoshein commented on code in PR #13562:
URL: https://github.com/apache/kafka/pull/13562#discussion_r1271470073
##
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
ruslankrivoshein commented on code in PR #13562:
URL: https://github.com/apache/kafka/pull/13562#discussion_r1271470073
##
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
ruslankrivoshein commented on code in PR #13562:
URL: https://github.com/apache/kafka/pull/13562#discussion_r1271470073
##
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
ocadaruma commented on PR #10167:
URL: https://github.com/apache/kafka/pull/10167#issuecomment-1646844923
@hudeqi Yeah, that's right. The problem still exists. I'll share my thoughts
in KIP-842 discussion thread.
--
This is an automated message from the Apache Git Service.
To respond to t
bmscomp commented on code in PR #14075:
URL: https://github.com/apache/kafka/pull/14075#discussion_r1271437691
##
build.gradle:
##
@@ -808,10 +809,9 @@ if (userEnableTestCoverage) {
executionData.from = javaProjects.jacocoTestReport.executionData
reports {
- htm
bmscomp commented on code in PR #14075:
URL: https://github.com/apache/kafka/pull/14075#discussion_r1271437161
##
build.gradle:
##
@@ -808,10 +809,9 @@ if (userEnableTestCoverage) {
executionData.from = javaProjects.jacocoTestReport.executionData
reports {
- htm
bmscomp commented on code in PR #14075:
URL: https://github.com/apache/kafka/pull/14075#discussion_r1271437161
##
build.gradle:
##
@@ -808,10 +809,9 @@ if (userEnableTestCoverage) {
executionData.from = javaProjects.jacocoTestReport.executionData
reports {
- htm
maniekes commented on PR #13321:
URL: https://github.com/apache/kafka/pull/13321#issuecomment-1646799859
hi @divijvaidya what do u think about my last 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 ab
vamossagar12 commented on PR #14051:
URL: https://github.com/apache/kafka/pull/14051#issuecomment-1646786096
Thanks @showuon . oh I didn’t realise I could use spy in scala tests as
well. Sorry I missed that and thanks for your help.
--
This is an automated message from the Apache Git Ser
showuon commented on PR #14051:
URL: https://github.com/apache/kafka/pull/14051#issuecomment-1646779495
@vamossagar12 , sorry for late response.
For your suggestion:
> Remove the canAddReplicaToIsr call from
[here](https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/
43 matches
Mail list logo
