[
https://issues.apache.org/jira/browse/KAFKA-13431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582373#comment-17582373
]
Diego Erdody commented on KAFKA-13431:
--
Hi [~yash.mayya] . No, I'm not planning to
[
https://issues.apache.org/jira/browse/KAFKA-14000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582346#comment-17582346
]
Sagar Rao commented on KAFKA-14000:
---
hi [~xinzou] , Thanks for filing the bug. One thi
[
https://issues.apache.org/jira/browse/KAFKA-13914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-13914.
-
Fix Version/s: 3.3.0
Resolution: Fixed
> Implement kafka-metadata-quorum.sh
> ---
dengziming commented on PR #12469:
URL: https://github.com/apache/kafka/pull/12469#issuecomment-1221354360
Thanks for your patience @hachikuji
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14091:
--
Description:
Right now, if a task running with exactly-once support is killed ungracefully,
i
hachikuji merged PR #12469:
URL: https://github.com/apache/kafka/pull/12469
--
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.apach
C0urante commented on code in PR #12544:
URL: https://github.com/apache/kafka/pull/12544#discussion_r950708756
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java:
##
@@ -983,7 +983,7 @@ private List
sinkTaskReporters(ConnectorTaskId id, SinkConnectorC
C0urante commented on PR #12544:
URL: https://github.com/apache/kafka/pull/12544#issuecomment-1221326257
@mimaison if you have a moment, would you mind giving this a pass?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
C0urante opened a new pull request, #12544:
URL: https://github.com/apache/kafka/pull/12544
[Jira](https://issues.apache.org/jira/browse/KAFKA-14098)
Adds the client ID `connect-cluster-${groupId}-${topic}` to the producers
and consumers used by Connect workers to interact with intern
C0urante commented on code in PR #12536:
URL: https://github.com/apache/kafka/pull/12536#discussion_r950692858
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java:
##
@@ -409,6 +412,13 @@ public String groupId() {
return null;
}
+
songnon commented on code in PR #12543:
URL: https://github.com/apache/kafka/pull/12543#discussion_r950692749
##
core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala:
##
@@ -490,6 +490,41 @@ class ControllerIntegrationTest extends QuorumTestHarness {
[
https://issues.apache.org/jira/browse/KAFKA-14012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14012:
--
Fix Version/s: 3.4.0
> passing a "method" into the `Utils.closeQuietly` method cause NPE
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14007:
--
Fix Version/s: 3.4.0
> Connect header converters are never closed
> --
[
https://issues.apache.org/jira/browse/KAFKA-14000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14000:
-
Assignee: Sagar Rao
> Kafka-connect standby server shows empty tasks list
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14015:
-
Assignee: Sagar Rao
> ConfigProvider with ttl fails to restart tasks
>
[
https://issues.apache.org/jira/browse/KAFKA-14012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-14012.
---
Resolution: Fixed
> passing a "method" into the `Utils.closeQuietly` method cause NPE
>
[
https://issues.apache.org/jira/browse/KAFKA-14007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-14007.
---
Resolution: Fixed
> Connect header converters are never closed
> ---
vamossagar12 commented on PR #12485:
URL: https://github.com/apache/kafka/pull/12485#issuecomment-1221262360
Thanks @C0urante . I think those are great points and I now realise the
mistake I made with the PR. Here's what I am thinking and the answers to the
rest of your points =>
1)
dajac commented on code in PR #12501:
URL: https://github.com/apache/kafka/pull/12501#discussion_r950665710
##
core/src/main/scala/kafka/server/KafkaConfig.scala:
##
@@ -1295,7 +1298,8 @@ object KafkaConfig {
.define(TransactionsAbortTimedOutTransactionCleanupIntervalMsPr
19 matches
Mail list logo
