[GitHub] [kafka] wangxianghu closed pull request #11210: KAFKA-13199: Make Task extends Versioned

2021-08-13 Thread GitBox
wangxianghu closed pull request #11210: URL: https://github.com/apache/kafka/pull/11210 -- 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-unsub

[GitHub] [kafka] wangxianghu commented on pull request #11210: KAFKA-13199: Make Task extends Versioned

2021-08-13 Thread GitBox
wangxianghu commented on pull request #11210: URL: https://github.com/apache/kafka/pull/11210#issuecomment-898293032 reopen to trigger the ci -- 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

[jira] [Updated] (KAFKA-10493) KTable out-of-order updates are not being ignored

2021-08-13 Thread Nicholas Telford (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Telford updated KAFKA-10493: - Attachment: out-of-order-table.png > KTable out-of-order updates are not being ignored >

[jira] [Commented] (KAFKA-10493) KTable out-of-order updates are not being ignored

2021-08-13 Thread Nicholas Telford (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398550#comment-17398550 ] Nicholas Telford commented on KAFKA-10493: -- This issue is quite serious, becaus

[jira] [Commented] (KAFKA-13191) Kafka 2.8 - simultaneous restarts of Kafka and zookeeper result in broken cluster

2021-08-13 Thread afusr (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398594#comment-17398594 ] afusr commented on KAFKA-13191: --- I have been able to replicate this issue using the conflu

[jira] [Issue Comment Deleted] (KAFKA-13191) Kafka 2.8 - simultaneous restarts of Kafka and zookeeper result in broken cluster

2021-08-13 Thread afusr (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] afusr updated KAFKA-13191: -- Comment: was deleted (was: I have been able to replicate this issue using the confluent 6.2 images, please se

[jira] [Commented] (KAFKA-13191) Kafka 2.8 - simultaneous restarts of Kafka and zookeeper result in broken cluster

2021-08-13 Thread CS User (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398596#comment-17398596 ] CS User commented on KAFKA-13191: - I have been able to replicate this issue using the co

[GitHub] [kafka] SkyTianTian removed a comment on pull request #10277: KAFKA-9914: Fix replication cycle detection

2021-08-13 Thread GitBox
SkyTianTian removed a comment on pull request #10277: URL: https://github.com/apache/kafka/pull/10277#issuecomment-897736948 Hi, is there anyone who knows any workaround to avoid this heartbeat issue temporarily? -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [kafka] vamossagar12 opened a new pull request #11211: KAFKA-12960: Enforcing strict retention time for WindowStore and Sess…

2021-08-13 Thread GitBox
vamossagar12 opened a new pull request #11211: URL: https://github.com/apache/kafka/pull/11211 WindowedStore and SessionStore do not implement a strict retention time in general. We should consider to make retention time strict: even if we still have some record in the store (due to the se

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

2021-08-13 Thread GitBox
vamossagar12 commented on pull request #11211: URL: https://github.com/apache/kafka/pull/11211#issuecomment-898431720 @mjsax , @ableegoldman plz review when you get the chance. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

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

2021-08-13 Thread GitBox
vamossagar12 commented on pull request #11076: URL: https://github.com/apache/kafka/pull/11076#issuecomment-898433039 @ableegoldman plz review whenever you get the chance... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

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

2021-08-13 Thread GitBox
vamossagar12 commented on pull request #10798: URL: https://github.com/apache/kafka/pull/10798#issuecomment-898433681 @cadonna , @guozhangwang plz review the numbers whenever you get the chance... -- This is an automated message from the Apache Git Service. To respond to the message, pl

[jira] [Created] (KAFKA-13200) Fix version of MirrorMaker2 connectors

2021-08-13 Thread Mickael Maison (Jira)
Mickael Maison created KAFKA-13200: -- Summary: Fix version of MirrorMaker2 connectors Key: KAFKA-13200 URL: https://issues.apache.org/jira/browse/KAFKA-13200 Project: Kafka Issue Type: Improv

[GitHub] [kafka] smccauliff commented on a change in pull request #11204: KAFKA-13188 - Release the memory back into MemoryPool

2021-08-13 Thread GitBox
smccauliff commented on a change in pull request #11204: URL: https://github.com/apache/kafka/pull/11204#discussion_r688600716 ## File path: clients/src/main/java/org/apache/kafka/clients/ClientResponseWithFinalize.java ## @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache Softwa

[GitHub] [kafka] mimaison opened a new pull request #11212: KAFKA-13200: Fix MirrorMaker2 connector version

2021-08-13 Thread GitBox
mimaison opened a new pull request #11212: URL: https://github.com/apache/kafka/pull/11212 Use the Kafka version instead of hardcoding it to 1. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build

[jira] [Commented] (KAFKA-12908) Load snapshot heuristic

2021-08-13 Thread dengziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398747#comment-17398747 ] dengziming commented on KAFKA-12908: It seems we can't write the number of records i

[jira] [Comment Edited] (KAFKA-12908) Load snapshot heuristic

2021-08-13 Thread dengziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398747#comment-17398747 ] dengziming edited comment on KAFKA-12908 at 8/13/21, 3:46 PM:

[jira] [Commented] (KAFKA-10475) Using same key reports different count of records for groupBy() and groupByKey() in Kafka Streaming Application

2021-08-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398781#comment-17398781 ] Matthias J. Sax commented on KAFKA-10475: - In the end `groupBy(...)` and `groupB

[GitHub] [kafka] ryannedolan commented on pull request #11212: KAFKA-13200: Fix MirrorMaker2 connector version

2021-08-13 Thread GitBox
ryannedolan commented on pull request #11212: URL: https://github.com/apache/kafka/pull/11212#issuecomment-898647966 Does this have any impact on users as they upgrade? So far the MM connectors are mostly agnostic to what version of Kafka they interact with, and I'm wondering if syncing th

[GitHub] [kafka] xvrl commented on a change in pull request #11201: MINOR: fix mbean tag name ordering in JMX reporter

2021-08-13 Thread GitBox
xvrl commented on a change in pull request #11201: URL: https://github.com/apache/kafka/pull/11201#discussion_r688708853 ## File path: clients/src/test/java/org/apache/kafka/common/metrics/JmxReporterTest.java ## @@ -76,6 +77,21 @@ public void testJmxRegistration() throws Exce

[GitHub] [kafka] xvrl commented on pull request #11201: MINOR: fix mbean tag name ordering in JMX reporter

2021-08-13 Thread GitBox
xvrl commented on pull request #11201: URL: https://github.com/apache/kafka/pull/11201#issuecomment-898649031 @dajac agree there might be some surprises for users that relied on ordering that might appear constant, but never guaranteed that. Unfortunately, that order would be dependent on

[jira] [Created] (KAFKA-13201) Convert KTable suppress to new PAPI

2021-08-13 Thread Jorge Esteban Quilcate Otoya (Jira)
Jorge Esteban Quilcate Otoya created KAFKA-13201: Summary: Convert KTable suppress to new PAPI Key: KAFKA-13201 URL: https://issues.apache.org/jira/browse/KAFKA-13201 Project: Kafka

[GitHub] [kafka] jeqo opened a new pull request #11213: KAFKA-13201: Convert KTable aggregations to new PAPI

2021-08-13 Thread GitBox
jeqo opened a new pull request #11213: URL: https://github.com/apache/kafka/pull/11213 As part of the migration of KStream/KTable operations to the new Processor API https://issues.apache.org/jira/browse/KAFKA-8410, this PR includes the migration of KTable suppress. Testing strategy

[jira] [Created] (KAFKA-13202) KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

2021-08-13 Thread Kirk True (Jira)
Kirk True created KAFKA-13202: - Summary: KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC Key: KAFKA-13202 URL: https://issues.apache.org/jira/browse/KAFKA-13202 Project: Kafka Issue Type:

[GitHub] [kafka] rhauch commented on a change in pull request #10907: KAFKA-10000: Exactly-once support for source connectors (KIP-618)

2021-08-13 Thread GitBox
rhauch commented on a change in pull request #10907: URL: https://github.com/apache/kafka/pull/10907#discussion_r688675632 ## File path: connect/api/src/main/java/org/apache/kafka/connect/source/SourceTaskContext.java ## @@ -38,4 +38,30 @@ * Get the OffsetStorageReader f

[GitHub] [kafka] mimaison commented on pull request #11212: KAFKA-13200: Fix MirrorMaker2 connector version

2021-08-13 Thread GitBox
mimaison commented on pull request #11212: URL: https://github.com/apache/kafka/pull/11212#issuecomment-898708844 This should not have an impact. As far as I can tell the version is only externally visible when querying `/connector-plugins`. When we have a bunch of Connect clusters w

[GitHub] [kafka] lbradstreet commented on pull request #11199: KAFKA-13194: bound cleaning by both LSO and HWM when firstUnstableOffsetMetadata is None

2021-08-13 Thread GitBox
lbradstreet commented on pull request #11199: URL: https://github.com/apache/kafka/pull/11199#issuecomment-898750464 > @lbradstreet : Thanks for the updated PR. Were the java 16 tests ok? @junrao it looks like it is one of the issues where System.exit was called without the Exit.exit

[GitHub] [kafka] junrao merged pull request #11199: KAFKA-13194: bound cleaning by both LSO and HWM when firstUnstableOffsetMetadata is None

2021-08-13 Thread GitBox
junrao merged pull request #11199: URL: https://github.com/apache/kafka/pull/11199 -- 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..

[jira] [Resolved] (KAFKA-13194) LogCleaner may clean past highwatermark

2021-08-13 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13194. - Fix Version/s: 3.1.0 Assignee: Lucas Bradstreet Resolution: Fixed Merged the PR to trunk

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

2021-08-13 Thread Andrew patterson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398977#comment-17398977 ] Andrew patterson commented on KAFKA-12994: -- Hello, I'd be happy to take this i

[jira] [Updated] (KAFKA-13186) Proposal for commented code

2021-08-13 Thread CoolGuy (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] CoolGuy updated KAFKA-13186: Description: Hello! I saw in your [coding guidelines|https://kafka.apache.org/coding-guide.html] that ??D

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

2021-08-13 Thread Christo Lolov (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17399110#comment-17399110 ] Christo Lolov commented on KAFKA-12994: --- Hello, I believe I managed to get some of

[GitHub] [kafka] clolov opened a new pull request #11214: KAFKA-12994 Migrate JoinWindowsTests to new API

2021-08-13 Thread GitBox
clolov opened a new pull request #11214: URL: https://github.com/apache/kafka/pull/11214 *This is a follow-up task connected with KIP-633 to update APIs used in unit tests* ### Committer Checklist (excluded from commit message) - [] Verify design and implementation - [] Verify

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

2021-08-13 Thread Christo Lolov (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17399110#comment-17399110 ] Christo Lolov edited comment on KAFKA-12994 at 8/14/21, 6:36 AM: -