vahidhashemian commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r637664106
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -80,9 +80,7 @@ public
dengziming commented on pull request #10748:
URL: https://github.com/apache/kafka/pull/10748#issuecomment-846699211
ping @mumrah for a review, maybe you forgot it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
dengziming opened a new pull request #10748:
URL: https://github.com/apache/kafka/pull/10748
*More detailed description of your change*
#10504 bump apiversion to 3.0.0, we'd better also add test for it.
*Summary of testing strategy (including rationale)*
Unit test
--
fqaiser94 commented on a change in pull request #10747:
URL: https://github.com/apache/kafka/pull/10747#discussion_r637657442
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java
##
@@ -45,34 +45,30 @@ public void
fqaiser94 opened a new pull request #10747:
URL: https://github.com/apache/kafka/pull/10747
# Problem
For context, this issue was initially raised in the following
[
https://issues.apache.org/jira/browse/KAFKA-12773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350212#comment-17350212
]
loboxu commented on KAFKA-12773:
ok
> Use UncheckedIOException when wrapping IOException
>
[
https://issues.apache.org/jira/browse/KAFKA-12839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12839:
Summary: SlidingWindow with timeDifference zero fails (was: SlidingWindow
with
[
https://issues.apache.org/jira/browse/KAFKA-12839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12839:
Summary: SlidingWindow with timeDifference 0 fails (was: SlidingWindow
with size 0
mjsax commented on pull request #10722:
URL: https://github.com/apache/kafka/pull/10722#issuecomment-846673350
Thanks for the PR @showuon! Merged 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
URL
mjsax merged pull request #10722:
URL: https://github.com/apache/kafka/pull/10722
--
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.
For queries about this service, please
[
https://issues.apache.org/jira/browse/KAFKA-12839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12839:
Labels: needs-kip (was: )
> SlidingWindow with size 0 fails
>
satishd commented on pull request #10733:
URL: https://github.com/apache/kafka/pull/10733#issuecomment-846647638
@junrao @kowshik Please review the PR.
--
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
[
https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350117#comment-17350117
]
Sagar Rao edited comment on KAFKA-8295 at 5/23/21, 6:54 PM:
[~ableegoldman],
[
https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350118#comment-17350118
]
Sagar Rao commented on KAFKA-9168:
--
[~ableegoldman], looks like Bruno has done his work on
[
https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350117#comment-17350117
]
Sagar Rao commented on KAFKA-8295:
--
[~ableegoldman], So, I extended the rocksjava benchmarking code
[
https://issues.apache.org/jira/browse/KAFKA-12773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350078#comment-17350078
]
Jose Armando Garcia Sancio commented on KAFKA-12773:
No KIP is required for this
KahnCheny opened a new pull request #10746:
URL: https://github.com/apache/kafka/pull/10746
remove unneccessary public keyword from ProducerInterceptor interface
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
tang7526 commented on a change in pull request #10534:
URL: https://github.com/apache/kafka/pull/10534#discussion_r637506753
##
File path: core/src/main/scala/kafka/log/LogSegment.scala
##
@@ -162,15 +162,43 @@ class LogSegment private[log] (val log: FileRecords,
//
tang7526 commented on a change in pull request #10534:
URL: https://github.com/apache/kafka/pull/10534#discussion_r637506676
##
File path: core/src/main/scala/kafka/log/LogSegment.scala
##
@@ -162,15 +162,43 @@ class LogSegment private[log] (val log: FileRecords,
//
19 matches
Mail list logo
