[GitHub] [kafka] dengziming closed pull request #8941: KAFKA-10195: Move offset management code out of ConsumerCoordinator

dengziming closed pull request #8941: URL: https://github.com/apache/kafka/pull/8941 -- 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:

[GitHub] [kafka] dengziming closed pull request #9734: KAFKA-10845; Add VisibleForTesting annotation

dengziming closed pull request #9734: URL: https://github.com/apache/kafka/pull/9734 -- 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] [Updated] (KAFKA-13291) Using Stateful Blue/Green Deployment to handle Application Evolvement

[ https://issues.apache.org/jira/browse/KAFKA-13291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhihao Wang updated KAFKA-13291: Description: Application Evolvement is an open problem in streaming processing. We present a

[jira] [Created] (KAFKA-13291) Using Stateful Blue/Green Deployment to handle Application Evolvement

Zhihao Wang created KAFKA-13291: --- Summary: Using Stateful Blue/Green Deployment to handle Application Evolvement Key: KAFKA-13291 URL: https://issues.apache.org/jira/browse/KAFKA-13291 Project: Kafka

[GitHub] [kafka] dengziming commented on pull request #11321: MINOR: Replace EasyMock with Mockito in connect:basic-auth-extension

dengziming commented on pull request #11321: URL: https://github.com/apache/kafka/pull/11321#issuecomment-917368038 ping @ijuma @mageshn to have a look. -- 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

[jira] [Commented] (KAFKA-13286) Revisit Streams State Store and Serde Implementation

[ https://issues.apache.org/jira/browse/KAFKA-13286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413490#comment-17413490 ] Sagar Rao commented on KAFKA-13286: --- [~guozhang], thanks for notifying about this on the PR link. I

[GitHub] [kafka] vamossagar12 commented on pull request #10798: KAFKA-9168: Adding direct byte buffer support to rocksdb state store

vamossagar12 commented on pull request #10798: URL: https://github.com/apache/kafka/pull/10798#issuecomment-917365748 hey @guozhangwang , that makes perfect sense to me. Based upon the discussion me and @patrickstuedi had on this thread, I think to reap the real benefits, the

[GitHub] [kafka] vamossagar12 commented on pull request #11076: KAFKA-12486: Enforce Rebalance when a TaskCorruptedException is throw…

vamossagar12 commented on pull request #11076: URL: https://github.com/apache/kafka/pull/11076#issuecomment-917364261 Also, I see 2 failing tests: `IntegrationTestUtils.startApplicationAndWaitUntilRunning` and

[GitHub] [kafka] vamossagar12 commented on pull request #11076: KAFKA-12486: Enforce Rebalance when a TaskCorruptedException is throw…

vamossagar12 commented on pull request #11076: URL: https://github.com/apache/kafka/pull/11076#issuecomment-917364082 @ableegoldman , I made the couple of changes you had requested. Would it be possible to look at this one again whenever you get the chance? -- This is an automated

[GitHub] [kafka] vamossagar12 commented on a change in pull request #11211: KAFKA-12960: Enforcing strict retention time for WindowStore and Sess…

vamossagar12 commented on a change in pull request #11211: URL: https://github.com/apache/kafka/pull/11211#discussion_r706578593 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java ## @@ -292,13 +408,46 @@ public V fetch(final

[GitHub] [kafka] vamossagar12 commented on a change in pull request #11211: KAFKA-12960: Enforcing strict retention time for WindowStore and Sess…

vamossagar12 commented on a change in pull request #11211: URL: https://github.com/apache/kafka/pull/11211#discussion_r706578593 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java ## @@ -292,13 +408,46 @@ public V fetch(final

[jira] [Commented] (KAFKA-12994) Migrate all Tests to New API and Remove Suppression for Deprecation Warnings related to KIP-633

[ https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413480#comment-17413480 ] Christo Lolov commented on KAFKA-12994: --- [~ableegoldman] Thank you for the comments, approval and

[jira] [Commented] (KAFKA-13227) Cancel pending AlterIsr requests after receiving LeaderAndIsr

[ https://issues.apache.org/jira/browse/KAFKA-13227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413479#comment-17413479 ] Christo Lolov commented on KAFKA-13227: --- [~hachikuji] Apologies for the delay, I wasn't able to

[GitHub] [kafka] dengziming opened a new pull request #11321: MINOR: Replace EasyMock with Mockito in connect:basic-auth-extension

dengziming opened a new pull request #11321: URL: https://github.com/apache/kafka/pull/11321 *More detailed description of your change* Replace EasyMock with Mockito in connect:basic-auth-extension -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [kafka] satishd commented on pull request #11058: KAFKA-12802 Added a file based cache for consumed remote log metadata for each partition to avoid consuming again incase of broker restarts.

satishd commented on pull request #11058: URL: https://github.com/apache/kafka/pull/11058#issuecomment-917351522 @junrao Rebased the PR and resolved the conflicts, thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and