[GitHub] [kafka] patrickstuedi commented on a change in pull request #11234: KAFKA-13212: add support infinite query for session store

2021-10-04 Thread GitBox
patrickstuedi commented on a change in pull request #11234: URL: https://github.com/apache/kafka/pull/11234#discussion_r720243284 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java ## @@ -212,18 +216,15 @@ public void remove(f

[GitHub] [kafka] showuon commented on a change in pull request #11234: KAFKA-13212: add support infinite query for session store

2021-10-04 Thread GitBox
showuon commented on a change in pull request #11234: URL: https://github.com/apache/kafka/pull/11234#discussion_r721153713 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java ## @@ -351,10 +345,8 @@ public V fetchSession(final

[GitHub] [kafka] showuon commented on a change in pull request #11234: KAFKA-13212: add support infinite query for session store

2021-10-04 Thread GitBox
showuon commented on a change in pull request #11234: URL: https://github.com/apache/kafka/pull/11234#discussion_r721155436 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java ## @@ -212,18 +216,15 @@ public void remove(final W

[GitHub] [kafka] wenzelcheng opened a new pull request #11377: MINOR: Use try-with-resource to close the stream opened by Files.list()

2021-10-04 Thread GitBox
wenzelcheng opened a new pull request #11377: URL: https://github.com/apache/kafka/pull/11377 It may cause the file handle not to be released. -- 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

[GitHub] [kafka] wenzelcheng commented on pull request #11377: MINOR: Use try-with-resource to close the stream opened by Files.list()

2021-10-04 Thread GitBox
wenzelcheng commented on pull request #11377: URL: https://github.com/apache/kafka/pull/11377#issuecomment-933342185 @ijuma @tombentley request for review. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

[jira] [Created] (KAFKA-13343) kafka-topics.sh throws error with the step3 command of quickstart's steps

2021-10-04 Thread liyunhua (Jira)
liyunhua created KAFKA-13343: Summary: kafka-topics.sh throws error with the step3 command of quickstart's steps Key: KAFKA-13343 URL: https://issues.apache.org/jira/browse/KAFKA-13343 Project: Kafka

[jira] [Updated] (KAFKA-13343) kafka-topics.sh throws error with the step3 command of quickstart's steps

2021-10-04 Thread liyunhua (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liyunhua updated KAFKA-13343: - Description: https://kafka.apache.org/quickstart   i'm a new comer to kafka, so i learn by QUICKSTART,

[jira] [Updated] (KAFKA-13343) kafka-topics.sh throws error with the step3 command of quickstart's steps

2021-10-04 Thread liyunhua (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liyunhua updated KAFKA-13343: - Description: [链接标题|https://kafka.apache.org/quickstart]    i'm a new comer to kafka, so i learn by QUI

[GitHub] [kafka] mimaison commented on pull request #11220: KAFKA-10777: Add additional configuration to control MirrorMaker 2 internal topics naming convention

2021-10-04 Thread GitBox
mimaison commented on pull request #11220: URL: https://github.com/apache/kafka/pull/11220#issuecomment-933433123 @OmniaGM Sorry for the delay, I was away for a few weeks. I'm back now and I'll take a look -- This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [kafka] chia7712 opened a new pull request #11378: MINOR: The message of BufferExhaustedException should include pool st…

2021-10-04 Thread GitBox
chia7712 opened a new pull request #11378: URL: https://github.com/apache/kafka/pull/11378 Including the pool status can help us to understand what happens in the moment. The new message is shown below. ` Failed to allocate 200 bytes within the configured max blocking time 10 ms. Tot

[jira] [Commented] (KAFKA-13343) kafka-topics.sh throws error with the step3 command of quickstart's steps

2021-10-04 Thread Joel Wiegman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423982#comment-17423982 ] Joel Wiegman commented on KAFKA-13343: -- Agreed.  The partitions argument says "If n

[jira] [Comment Edited] (KAFKA-13343) kafka-topics.sh throws error with the step3 command of quickstart's steps

2021-10-04 Thread Joel Wiegman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423982#comment-17423982 ] Joel Wiegman edited comment on KAFKA-13343 at 10/4/21, 2:51 PM: --

[GitHub] [kafka] officialpatterson opened a new pull request #11379: kafka-12994: Migrated SlidingWindowsTest to new API

2021-10-04 Thread GitBox
officialpatterson opened a new pull request #11379: URL: https://github.com/apache/kafka/pull/11379 As raised in KAFKA-12994, All tests that use the old API should be either eliminated or migrated to the new API in order to remove the @SuppressWarnings("deprecation") annotations. Th

[GitHub] [kafka] mimaison commented on a change in pull request #11220: KAFKA-10777: Add additional configuration to control MirrorMaker 2 internal topics naming convention

2021-10-04 Thread GitBox
mimaison commented on a change in pull request #11220: URL: https://github.com/apache/kafka/pull/11220#discussion_r721467669 ## File path: connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/ReplicationPolicy.java ## @@ -52,9 +52,39 @@ default String originalTo

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

2021-10-04 Thread Andrew patterson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17424004#comment-17424004 ] Andrew patterson commented on KAFKA-12994: -- Next and final PR is here [https://

[GitHub] [kafka] mimaison commented on pull request #11276: KAFKA-13240: Disable HTTP TRACE Method in Connect

2021-10-04 Thread GitBox
mimaison commented on pull request #11276: URL: https://github.com/apache/kafka/pull/11276#issuecomment-933613268 @viktorsomogyi Thanks for the PR. I think we should do a small KIP for this change. There may be users relying on HTTP TRACE today. -- This is an automated message from the A

[GitHub] [kafka] mimaison commented on pull request #8984: KAFKA-10227: Enforce cleanup policy to only contain compact or delete once

2021-10-04 Thread GitBox
mimaison commented on pull request #8984: URL: https://github.com/apache/kafka/pull/8984#issuecomment-933614436 @huxihx can you rebase your PR? Thanks -- 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 g

[GitHub] [kafka] ccding commented on pull request #11345: Allow empty last segment to have missing offset index during recovery

2021-10-04 Thread GitBox
ccding commented on pull request #11345: URL: https://github.com/apache/kafka/pull/11345#issuecomment-933622186 While I am working on the test, I have a question: The `log.flush()` function is also called at https://github.com/apache/kafka/blob/db42afd6e24ef4291390b4d1c1f10758beedefe

[GitHub] [kafka] mimaison commented on pull request #11174: KAFKA-9747: Creating connect reconfiguration URL safely

2021-10-04 Thread GitBox
mimaison commented on pull request #11174: URL: https://github.com/apache/kafka/pull/11174#issuecomment-933641417 Applied to 3.0: https://github.com/apache/kafka/commit/9218b8cc5f10a1fb79c74e9a49ab36fd51e68916 -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (KAFKA-9747) No tasks created for a connector

2021-10-04 Thread Mickael Maison (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison updated KAFKA-9747: -- Fix Version/s: 3.0.1 > No tasks created for a connector > > >

[jira] [Updated] (KAFKA-12762) Use connection timeout when polling the network for new connections

2021-10-04 Thread Mickael Maison (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison updated KAFKA-12762: --- Fix Version/s: 3.0.1 > Use connection timeout when polling the network for new connections >

[GitHub] [kafka] akatona84 commented on pull request #11373: MINOR: Add shebang to gradlewAll

2021-10-04 Thread GitBox
akatona84 commented on pull request #11373: URL: https://github.com/apache/kafka/pull/11373#issuecomment-933672624 @granthenke , could you take a look as well? Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[GitHub] [kafka] jolshan commented on pull request #11331: KAFKA-13111: Re-evaluate Fetch Sessions when using topic IDs

2021-10-04 Thread GitBox
jolshan commented on pull request #11331: URL: https://github.com/apache/kafka/pull/11331#issuecomment-933821031 @ijuma > Thanks for the PR. A high-level question, what are we trying to optimize for here? >Requests that don't include topic ids Requests that include topic ids Bo

[jira] [Commented] (KAFKA-13261) KTable to KTable foreign key join loose events when using several partitions

2021-10-04 Thread Tomas Forsman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17424158#comment-17424158 ] Tomas Forsman commented on KAFKA-13261: --- [~vcrfxia] thank you so much for solving

[jira] [Created] (KAFKA-13344) In a Kafka Cluster (3 brokers), I am trying to consume message from single broker. When the broker is down, I am continuing to traffic messages from consumer because oth

2021-10-04 Thread Pakkiyarasu P (Jira)
Pakkiyarasu P created KAFKA-13344: - Summary: In a Kafka Cluster (3 brokers), I am trying to consume message from single broker. When the broker is down, I am continuing to traffic messages from consumer because other 2 brokers are running.

[jira] [Created] (KAFKA-13345) WindowStore should use "delete" policy when duplicates are enabled

2021-10-04 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-13345: --- Summary: WindowStore should use "delete" policy when duplicates are enabled Key: KAFKA-13345 URL: https://issues.apache.org/jira/browse/KAFKA-13345 Project: Kaf

[jira] [Assigned] (KAFKA-13345) WindowStore should use "delete" policy when duplicates are enabled

2021-10-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13345: --- Assignee: Matthias J. Sax > WindowStore should use "delete" policy when duplicates

[GitHub] [kafka] mjsax opened a new pull request #11380: KAFKA-13345: Use "delete" cleanup policy for windowed stores if duplicates are enabled

2021-10-04 Thread GitBox
mjsax opened a new pull request #11380: URL: https://github.com/apache/kafka/pull/11380 Call for review @guozhangwang @cadonna -- 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 comme

[jira] [Commented] (KAFKA-13164) State store is attached to wrong node in the Kafka Streams topology

2021-10-04 Thread Hao Li (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17424296#comment-17424296 ] Hao Li commented on KAFKA-13164: Hi Ralph,   I was able to test it out with following

[jira] [Commented] (KAFKA-13326) Add multi-cluster support to Kafka Streams

2021-10-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17424298#comment-17424298 ] Matthias J. Sax commented on KAFKA-13326: - Neither mirror-maker2 not replicator

[jira] [Commented] (KAFKA-13339) Kstream not fetch all the messages

2021-10-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17424304#comment-17424304 ] Matthias J. Sax commented on KAFKA-13339: - The logs you shared don't contain any

[jira] [Resolved] (KAFKA-13339) Kstream not fetch all the messages

2021-10-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13339. - Resolution: Invalid > Kstream not fetch all the messages > -

[jira] [Updated] (KAFKA-13339) Kstream not fetch all the messages

2021-10-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13339: Component/s: (was: consumer) streams > Kstream not fetch all the mess

[jira] [Commented] (KAFKA-13164) State store is attached to wrong node in the Kafka Streams topology

2021-10-04 Thread Ralph Matthias Debusmann (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17424321#comment-17424321 ] Ralph Matthias Debusmann commented on KAFKA-13164: -- Hi Hao Li, thanks!