ruanwenjun commented on a change in pull request #11754:
URL: https://github.com/apache/kafka/pull/11754#discussion_r810426220
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -764,10 +764,7 @@ public static ByteBuffer ensureCapacity(ByteBuffer
ruanwenjun commented on a change in pull request #11754:
URL: https://github.com/apache/kafka/pull/11754#discussion_r810426220
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -764,10 +764,7 @@ public static ByteBuffer ensureCapacity(ByteBuffer
ijuma commented on a change in pull request #11788:
URL: https://github.com/apache/kafka/pull/11788#discussion_r810402844
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
##
@@ -461,27 +464,55 @@ private void
postProcessAndValidateIdem
ijuma commented on a change in pull request #11788:
URL: https://github.com/apache/kafka/pull/11788#discussion_r810402844
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
##
@@ -461,27 +464,55 @@ private void
postProcessAndValidateIdem
ijuma commented on a change in pull request #11788:
URL: https://github.com/apache/kafka/pull/11788#discussion_r810402844
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
##
@@ -461,27 +464,55 @@ private void
postProcessAndValidateIdem
C0urante commented on a change in pull request #10367:
URL: https://github.com/apache/kafka/pull/10367#discussion_r803045306
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java
##
@@ -532,23 +531,23 @@ pr
[
https://issues.apache.org/jira/browse/KAFKA-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494824#comment-17494824
]
shylaja kokoori commented on KAFKA-13418:
-
[~ijuma] Thank you. Let me test with
splett2 commented on a change in pull request #11754:
URL: https://github.com/apache/kafka/pull/11754#discussion_r810211960
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -764,10 +764,7 @@ public static ByteBuffer ensureCapacity(ByteBuffer
e
splett2 commented on a change in pull request #11754:
URL: https://github.com/apache/kafka/pull/11754#discussion_r810211960
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -764,10 +764,7 @@ public static ByteBuffer ensureCapacity(ByteBuffer
e
wcarlson5 commented on pull request #11791:
URL: https://github.com/apache/kafka/pull/11791#issuecomment-1044861346
@guozhangwang @ableegoldman This is ready for a pass when you have a sec
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
wcarlson5 opened a new pull request #11791:
URL: https://github.com/apache/kafka/pull/11791
When we hit an exception when processing tasks we should save the work we
have done so far.
This will only be relevant with ALOS, not EOS. It will actually reduce the
number of duplicated record
jlprat commented on pull request #11432:
URL: https://github.com/apache/kafka/pull/11432#issuecomment-1044848322
Hi @SethTisue thanks! I definitely will take a look at it!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
SethTisue edited a comment on pull request #11432:
URL: https://github.com/apache/kafka/pull/11432#issuecomment-1044840351
As an aside: once this lands it would be great to get Kafka in the Scala 3
community build. (Among other reasons, because there is a lot of Java code in
Kafka, and the
SethTisue commented on pull request #11432:
URL: https://github.com/apache/kafka/pull/11432#issuecomment-1044840351
As an aside: once this lands it would be great to get Kafka in the Scala 3
community build. I think VirtusLab hopes to support other build tools besides
sbt there eventually,
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r810019916
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,295
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r810019916
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,295
Walker Carlson created KAFKA-13676:
--
Summary: When processing in ALOS we might as well commit progress
made other tasks on a task specific exception
Key: KAFKA-13676
URL: https://issues.apache.org/jira/browse/KAF
wcarlson5 closed pull request #10544:
URL: https://github.com/apache/kafka/pull/10544
--
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-unsubsc
wcarlson5 closed pull request #10543:
URL: https://github.com/apache/kafka/pull/10543
--
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-unsubsc
lkokhreidze commented on pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#issuecomment-1044574529
Hi @showuon Thanks for the feedback.
I've addressed your comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r810020380
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,295
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r810019916
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,295
[
https://issues.apache.org/jira/browse/KAFKA-13666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-13666.
---
Resolution: Fixed
> Tests should not ignore exceptions for supported OS
> --
[
https://issues.apache.org/jira/browse/KAFKA-13666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13666:
--
Fix Version/s: 3.2.0
> Tests should not ignore exceptions for supported OS
> -
cadonna merged pull request #11752:
URL: https://github.com/apache/kafka/pull/11752
--
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.
cadonna commented on pull request #11752:
URL: https://github.com/apache/kafka/pull/11752#issuecomment-1044551717
Test failures are unrelated and known to be flaky.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/KAFKA-8541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494617#comment-17494617
]
Bruno Cadonna commented on KAFKA-8541:
--
Should we open a separate ticket for the Ass
[
https://issues.apache.org/jira/browse/KAFKA-8541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494616#comment-17494616
]
Bruno Cadonna commented on KAFKA-8541:
--
https://ci-builds.apache.org/job/Kafka/job/k
[
https://issues.apache.org/jira/browse/KAFKA-13672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494613#comment-17494613
]
Bruno Cadonna commented on KAFKA-13672:
---
https://ci-builds.apache.org/job/Kafka/jo
[
https://issues.apache.org/jira/browse/KAFKA-12511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494611#comment-17494611
]
Bruno Cadonna commented on KAFKA-12511:
---
https://ci-builds.apache.org/job/Kafka/jo
[
https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494610#comment-17494610
]
Bruno Cadonna commented on KAFKA-8391:
--
{code:java}
java.lang.AssertionError: Tasks
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r810003432
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,295
showuon commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r809980650
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StandbyTaskAssignmentUtils.java
##
@@ -0,0 +1,54 @@
+/*
+ * L
ruanwenjun commented on a change in pull request #11789:
URL: https://github.com/apache/kafka/pull/11789#discussion_r809894308
##
File path: core/src/main/scala/kafka/tools/StorageTool.scala
##
@@ -56,6 +55,11 @@ object StorageTool extends Logging {
formatParser.addArgum
showuon commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r809773328
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,295 @@
+
ableegoldman merged pull request #11738:
URL: https://github.com/apache/kafka/pull/11738
--
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-unsu
ableegoldman commented on a change in pull request #11738:
URL: https://github.com/apache/kafka/pull/11738#discussion_r809780324
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java
##
@@ -0,0 +1,267 @@
+/*
+ * Licensed to the Apac
ableegoldman commented on pull request #11738:
URL: https://github.com/apache/kafka/pull/11738#issuecomment-1044143849
Test failures are unrelated. Merging to trunk
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
38 matches
Mail list logo
