vamossagar12 commented on code in PR #13131:
URL: https://github.com/apache/kafka/pull/13131#discussion_r1083413458
##
core/src/main/scala/kafka/utils/ToolsUtils.scala:
##
@@ -64,4 +65,18 @@ object ToolsUtils {
println(s"%-${maxLengthOfDisplayName}s :
$specifier".forma
vamossagar12 commented on code in PR #13131:
URL: https://github.com/apache/kafka/pull/13131#discussion_r1083413458
##
core/src/main/scala/kafka/utils/ToolsUtils.scala:
##
@@ -64,4 +65,18 @@ object ToolsUtils {
println(s"%-${maxLengthOfDisplayName}s :
$specifier".forma
vamossagar12 commented on PR #13131:
URL: https://github.com/apache/kafka/pull/13131#issuecomment-1399432431
> @clolov @vamossagar12 took your suggestions. Thanks.
Thanks @fvaleri ! Couple of minor comments. This should be good to go after
that!
--
This is an automated message from
vamossagar12 commented on PR #12561:
URL: https://github.com/apache/kafka/pull/12561#issuecomment-1399432804
hwy @C0urante , I was thinking should the exponential backoff thing that we
have introduced as part of this PR should go somewhere in the docs? I am saying
this since this is a devia
mimaison opened a new pull request, #13145:
URL: https://github.com/apache/kafka/pull/13145
`Values.parseString()` handles empty strings and returns the same
`SchemaAndValue`
[[0]](https://github.com/apache/kafka/blob/trunk/connect/api/src/main/java/org/apache/kafka/connect/data/Values.java
mimaison commented on code in PR #13094:
URL: https://github.com/apache/kafka/pull/13094#discussion_r1083436604
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java:
##
@@ -331,17 +331,15 @@ public void testStressfulSituation() throws E
mimaison merged PR #13080:
URL: https://github.com/apache/kafka/pull/13080
--
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
[
https://issues.apache.org/jira/browse/KAFKA-13571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-13571:
---
Priority: Major (was: Blocker)
> Enabling MirrorMaker 2.0 with TLS
> --
[
https://issues.apache.org/jira/browse/KAFKA-14583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17679555#comment-17679555
]
Sagar Rao commented on KAFKA-14583:
---
This class has a dependency on `TopicFilter` whi
[
https://issues.apache.org/jira/browse/KAFKA-14583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17679555#comment-17679555
]
Sagar Rao edited comment on KAFKA-14583 at 1/22/23 1:20 PM:
hgeraldino opened a new pull request, #13146:
URL: https://github.com/apache/kafka/pull/13146
Companion PR for [KIP-901: Add flag connectorDeleted flag when stopping
task](https://cwiki.apache.org/confluence/display/KAFKA/KIP-901%3A+Add+flag+connectorDeleted+flag+when+stopping+task)
This
ableegoldman commented on PR #13141:
URL: https://github.com/apache/kafka/pull/13141#issuecomment-1399645849
test failures are unrelated, will merge to trunk and cherrypick to 3.4 to
help stabilize the release
--
This is an automated message from the Apache Git Service.
To respond to the
ableegoldman merged PR #13141:
URL: https://github.com/apache/kafka/pull/13141
--
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.ap
sgn2607 commented on code in PR #11748:
URL: https://github.com/apache/kafka/pull/11748#discussion_r1083630069
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java:
##
@@ -169,6 +172,7 @@ public String version() {
return listConsumer
sgn2607 commented on code in PR #11748:
URL: https://github.com/apache/kafka/pull/11748#discussion_r1083630069
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java:
##
@@ -169,6 +172,7 @@ public String version() {
return listConsumer
sgn2607 commented on code in PR #11748:
URL: https://github.com/apache/kafka/pull/11748#discussion_r1083630069
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java:
##
@@ -169,6 +172,7 @@ public String version() {
return listConsumer
abbccdda closed pull request #8725: KAFKA-9608: Transaction Event Simulation
Test
URL: https://github.com/apache/kafka/pull/8725
--
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.
fvaleri commented on code in PR #13131:
URL: https://github.com/apache/kafka/pull/13131#discussion_r1083709872
##
core/src/main/scala/kafka/utils/ToolsUtils.scala:
##
@@ -64,4 +65,18 @@ object ToolsUtils {
println(s"%-${maxLengthOfDisplayName}s :
$specifier".format(met
clolov commented on PR #12818:
URL: https://github.com/apache/kafka/pull/12818#issuecomment-1399926748
Thank you very much for the review and merge!
--
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 t
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov updated KAFKA-14133:
--
Description:
{color:#de350b}There are tests which use both PowerMock and EasyMock. I have
put
20 matches
Mail list logo
