[
https://issues.apache.org/jira/browse/KAFKA-13431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya reassigned KAFKA-13431:
--
Assignee: Yash Mayya (was: Diego Erdody)
> Sink Connectors: Support topic-mutating SMTs for
ashmeet13 commented on code in PR #12414:
URL: https://github.com/apache/kafka/pull/12414#discussion_r951002747
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1914,6 +1915,7 @@ public
CompletableFuture> createPartitions(
});
}
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582710#comment-17582710
]
Sagar Rao edited comment on KAFKA-12495 at 8/22/22 3:46 AM:
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582710#comment-17582710
]
Sagar Rao commented on KAFKA-12495:
---
Thanks [~showuon] for your comments.
Regarding
dengziming commented on code in PR #12414:
URL: https://github.com/apache/kafka/pull/12414#discussion_r950979470
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1914,6 +1915,7 @@ public
CompletableFuture> createPartitions(
});
}
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582706#comment-17582706
]
Luke Chen edited comment on KAFKA-12495 at 8/22/22 3:08 AM:
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582706#comment-17582706
]
Luke Chen commented on KAFKA-12495:
---
Sorry for the delay. My thoughts are below
>
RivenSun2 commented on PR #12539:
URL: https://github.com/apache/kafka/pull/12539#issuecomment-1221692785
Hi @showuon could you help review this PR?
Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
songnon commented on code in PR #12543:
URL: https://github.com/apache/kafka/pull/12543#discussion_r950920059
##
core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala:
##
@@ -490,6 +490,41 @@ class ControllerIntegrationTest extends QuorumTestHarness {
[
https://issues.apache.org/jira/browse/KAFKA-14000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582583#comment-17582583
]
Sagar Rao commented on KAFKA-14000:
---
[~ChrisEgerton] , Oh yeah.. Sorry I missed that.
[
https://issues.apache.org/jira/browse/KAFKA-14172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martin Hørslev updated KAFKA-14172:
---
Summary: bug: State stores lose state when tasks are reassigned under EOS
wit… (was: bug: S
[
https://issues.apache.org/jira/browse/KAFKA-14000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582582#comment-17582582
]
Chris Egerton commented on KAFKA-14000:
---
[~sagarrao] we do not recommend that the
ginaluca opened a new pull request, #12546:
URL: https://github.com/apache/kafka/pull/12546
Updated Javadoc on `MetricsReporter` to make the semantic of the
`metricsChange()` method more clear.
--
This is an automated message from the Apache Git Service.
To respond to the
showuon commented on PR #12542:
URL: https://github.com/apache/kafka/pull/12542#issuecomment-1221539556
I can't see where's the difference between `synchronized` and `inLock`,
either. Could you please explain more?
--
This is an automated message from the Apache Git Service.
To respond to
LinShunKang opened a new pull request, #12545:
URL: https://github.com/apache/kafka/pull/12545
# Motivation
* Reduce `Fetcher#parseRecord()` memory copy: we can direct use ByteBuffer
instead of byte[] to deserialize.
# Proposed Change
* `Deserializer` add default method `deseria
mdedetrich commented on PR #12475:
URL: https://github.com/apache/kafka/pull/12475#issuecomment-1221538822
@ijuma So I have added a commit which adds a workaround for the Scala
runtime conflict issues. The CI is failing but it appears it's not using the
updated `Jenkinsfile` in the commit s
[
https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582519#comment-17582519
]
Sagar Rao commented on KAFKA-14015:
---
[~rozza] , Thanks for filing this issue. There se
17 matches
Mail list logo
