[jira] [Commented] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to never emit events

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934171#comment-16934171 ] Michał commented on KAFKA-8924: --- Hi. Thanks a lot for such a detailed explanation. I think

[jira] [Comment Edited] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to never emit events

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934171#comment-16934171 ] Michał edited comment on KAFKA-8924 at 9/20/19 7:42 AM: Hi. Than

[jira] [Comment Edited] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to never emit events

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934171#comment-16934171 ] Michał edited comment on KAFKA-8924 at 9/20/19 7:42 AM: Hi. Than

[jira] [Comment Edited] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to never emit events

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934171#comment-16934171 ] Michał edited comment on KAFKA-8924 at 9/20/19 7:46 AM: Hi. Than

[jira] [Commented] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to never emit events

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934183#comment-16934183 ] John Roesler commented on KAFKA-8924: - Hi [~atais], Sorry again for the trouble. Re

[jira] [Commented] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to never emit events

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934187#comment-16934187 ] Michał commented on KAFKA-8924: --- {quote} Regarding the log message, that wasn't it, althoug

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934195#comment-16934195 ] Arunkumar Velusamy commented on KAFKA-7500: --- Hello Ryanne, I have executed few

[jira] [Comment Edited] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934195#comment-16934195 ] Arunkumar Velusamy edited comment on KAFKA-7500 at 9/20/19 8:26 AM: ---

[jira] [Comment Edited] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934195#comment-16934195 ] Arunkumar Velusamy edited comment on KAFKA-7500 at 9/20/19 8:29 AM: ---

[jira] [Comment Edited] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934195#comment-16934195 ] Arunkumar Velusamy edited comment on KAFKA-7500 at 9/20/19 8:35 AM: ---

[jira] [Comment Edited] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934195#comment-16934195 ] Arunkumar Velusamy edited comment on KAFKA-7500 at 9/20/19 8:37 AM: ---

[jira] [Comment Edited] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934195#comment-16934195 ] Arunkumar Velusamy edited comment on KAFKA-7500 at 9/20/19 8:38 AM: ---

[jira] [Comment Edited] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934195#comment-16934195 ] Arunkumar Velusamy edited comment on KAFKA-7500 at 9/20/19 8:39 AM: ---

[jira] [Comment Edited] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934195#comment-16934195 ] Arunkumar Velusamy edited comment on KAFKA-7500 at 9/20/19 8:40 AM: ---

[jira] [Commented] (KAFKA-6393) Add tool to view active brokers

[ https://issues.apache.org/jira/browse/KAFKA-6393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934231#comment-16934231 ] Viktor Somogyi-Vass commented on KAFKA-6393: Hey Jason, if you don't mind I'l

[jira] [Comment Edited] (KAFKA-6393) Add tool to view active brokers

[ https://issues.apache.org/jira/browse/KAFKA-6393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934231#comment-16934231 ] Viktor Somogyi-Vass edited comment on KAFKA-6393 at 9/20/19 9:23 AM: --

[jira] [Commented] (KAFKA-8848) Update system test to use new authorizer

[ https://issues.apache.org/jira/browse/KAFKA-8848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934289#comment-16934289 ] ASF GitHub Bot commented on KAFKA-8848: --- rajinisivaram commented on pull request #7

[jira] [Commented] (KAFKA-8742) Flaky Test RepartitionWithMergeOptimizingIntegrationTest#shouldSendCorrectResults_NO_OPTIMIZATION

[ https://issues.apache.org/jira/browse/KAFKA-8742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934399#comment-16934399 ] Rabi Kumar K C commented on KAFKA-8742: --- Ran the build and test for 500 times but w

[jira] [Commented] (KAFKA-8834) Distinguish URPs caused by reassignment plus other metrics

[ https://issues.apache.org/jira/browse/KAFKA-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934418#comment-16934418 ] Viktor Somogyi-Vass commented on KAFKA-8834: I think I was referring to a met

[jira] [Comment Edited] (KAFKA-8834) Distinguish URPs caused by reassignment plus other metrics

[ https://issues.apache.org/jira/browse/KAFKA-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934418#comment-16934418 ] Viktor Somogyi-Vass edited comment on KAFKA-8834 at 9/20/19 1:55 PM: --

[jira] [Comment Edited] (KAFKA-8834) Distinguish URPs caused by reassignment plus other metrics

[ https://issues.apache.org/jira/browse/KAFKA-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934418#comment-16934418 ] Viktor Somogyi-Vass edited comment on KAFKA-8834 at 9/20/19 1:55 PM: --

[jira] [Commented] (KAFKA-6883) KafkaShortnamer should allow to convert Kerberos principal name to upper case user name

[ https://issues.apache.org/jira/browse/KAFKA-6883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934477#comment-16934477 ] ASF GitHub Bot commented on KAFKA-6883: --- omkreddy commented on pull request #7375:

[jira] [Commented] (KAFKA-8834) Distinguish URPs caused by reassignment plus other metrics

[ https://issues.apache.org/jira/browse/KAFKA-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934505#comment-16934505 ] Jason Gustafson commented on KAFKA-8834: True, we could report lag from either th

[jira] [Created] (KAFKA-8930) MM2 documentation

Ryanne Dolan created KAFKA-8930: --- Summary: MM2 documentation Key: KAFKA-8930 URL: https://issues.apache.org/jira/browse/KAFKA-8930 Project: Kafka Issue Type: Improvement Components: d

[jira] [Created] (KAFKA-8929) MM2 system tests

Ryanne Dolan created KAFKA-8929: --- Summary: MM2 system tests Key: KAFKA-8929 URL: https://issues.apache.org/jira/browse/KAFKA-8929 Project: Kafka Issue Type: Improvement Components: mi

[jira] [Updated] (KAFKA-8928) Logged producer config does not always match actual config values

[ https://issues.apache.org/jira/browse/KAFKA-8928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8928: --- Component/s: clients > Logged producer config does not always match actual config values > --

[jira] [Created] (KAFKA-8928) Logged producer config does not always match actual config values

Chris Pettitt created KAFKA-8928: Summary: Logged producer config does not always match actual config values Key: KAFKA-8928 URL: https://issues.apache.org/jira/browse/KAFKA-8928 Project: Kafka

[jira] [Commented] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to never emit events

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934571#comment-16934571 ] John Roesler commented on KAFKA-8924: - Hey [~atais], Thanks for being proactive abou

[jira] [Updated] (KAFKA-8613) Set default grace period to 0

[ https://issues.apache.org/jira/browse/KAFKA-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8613: - Affects Version/s: (was: 3.0.0) > Set default grace period to 0 > ---

[jira] [Updated] (KAFKA-8613) Set default grace period to 0

[ https://issues.apache.org/jira/browse/KAFKA-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8613: - Fix Version/s: 3.0.0 > Set default grace period to 0 > - > >

[jira] [Updated] (KAFKA-7785) Move DefaultPartitionGrouper (and PartitionGrouper) to o.a.k.streams.processor.internals package

[ https://issues.apache.org/jira/browse/KAFKA-7785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7785: --- Fix Version/s: 3.0.0 > Move DefaultPartitionGrouper (and PartitionGrouper) to > o.a.k.stream

[jira] [Updated] (KAFKA-7785) Move DefaultPartitionGrouper (and PartitionGrouper) to o.a.k.streams.processor.internals package

[ https://issues.apache.org/jira/browse/KAFKA-7785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7785: --- Priority: Blocker (was: Minor) > Move DefaultPartitionGrouper (and PartitionGrouper) to > o

[jira] [Updated] (KAFKA-7785) Remove PartitionGrouper interface and it's config and move DefaultPartitionGrouper to internal package

[ https://issues.apache.org/jira/browse/KAFKA-7785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7785: --- Summary: Remove PartitionGrouper interface and it's config and move DefaultPartitionGrouper t

[jira] [Commented] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to never emit events

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934578#comment-16934578 ] Bruno Cadonna commented on KAFKA-8924: -- Maybe a bit off-topic in the meanwhile, but

[jira] [Updated] (KAFKA-7785) Remove PartitionGrouper interface and it's config and move DefaultPartitionGrouper to internal package

[ https://issues.apache.org/jira/browse/KAFKA-7785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7785: --- Description: Since {{DefaultPartitionGrouper}} is only for the purpose of the internal {{Str

[jira] [Updated] (KAFKA-7785) Remove PartitionGrouper interface and it's config and move DefaultPartitionGrouper to internal package

[ https://issues.apache.org/jira/browse/KAFKA-7785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7785: --- Description: Since {{DefaultPartitionGrouper}} is only for the purpose of the internal {{Str

[jira] [Commented] (KAFKA-8927) Remove config `partition.grouper` and interface `PartitionGrouper`

[ https://issues.apache.org/jira/browse/KAFKA-8927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934638#comment-16934638 ] ASF GitHub Bot commented on KAFKA-8927: --- mjsax commented on pull request #7376: KAF

[jira] [Updated] (KAFKA-8926) Log Cleaner thread dies when log.cleaner.min.cleanable.ratio is set to 0

[ https://issues.apache.org/jira/browse/KAFKA-8926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jordan Mcmillan updated KAFKA-8926: --- Description: I applied a dynamic configuration change using the following command: {code:bash

[jira] [Commented] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to never emit events

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934644#comment-16934644 ] Michał commented on KAFKA-8924: --- [~cadonna] as we discussed here I will adjust the TimeWind

[jira] [Comment Edited] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to never emit events

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934644#comment-16934644 ] Michał edited comment on KAFKA-8924 at 9/20/19 6:18 PM: [~cadonna

[jira] [Resolved] (KAFKA-8892) Display the sorted configs in Kafka Configs Help Command.

[ https://issues.apache.org/jira/browse/KAFKA-8892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-8892. -- Fix Version/s: 2.4.0 Resolution: Fixed Issue resolved by pull request 7319 [https://github.com/a

[jira] [Commented] (KAFKA-8892) Display the sorted configs in Kafka Configs Help Command.

[ https://issues.apache.org/jira/browse/KAFKA-8892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934649#comment-16934649 ] ASF GitHub Bot commented on KAFKA-8892: --- omkreddy commented on pull request #7319:

[jira] [Commented] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to never emit events

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934674#comment-16934674 ] Matthias J. Sax commented on KAFKA-8924: [~atais] – if you plan to reuse this Jir

[jira] [Updated] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to emit events after 24h

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał updated KAFKA-8924: -- Issue Type: Improvement (was: Bug) Summary: Default grace period (-1) of TimeWindows causes suppress to

[jira] [Commented] (KAFKA-8609) Add consumer metrics for rebalances (part 9)

[ https://issues.apache.org/jira/browse/KAFKA-8609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934855#comment-16934855 ] ASF GitHub Bot commented on KAFKA-8609: --- guozhangwang commented on pull request #73

[jira] [Reopened] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory

[ https://issues.apache.org/jira/browse/KAFKA-8319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-8319: -- > Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory >

[jira] [Commented] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory

[ https://issues.apache.org/jira/browse/KAFKA-8319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934867#comment-16934867 ] Guozhang Wang commented on KAFKA-8319: -- I've seen it again with the following error:

[jira] [Commented] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory

[ https://issues.apache.org/jira/browse/KAFKA-8319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934869#comment-16934869 ] Guozhang Wang commented on KAFKA-8319: -- Run locally 100 times, cannot see it again.

[jira] [Resolved] (KAFKA-7990) Flaky Test KafkaStreamsTest#shouldCleanupOldStateDirs

[ https://issues.apache.org/jira/browse/KAFKA-7990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7990. -- Fix Version/s: 2.3.0 2.2.1 Resolution: Fixed > Flaky Test KafkaStream

[jira] [Commented] (KAFKA-8913) Document topic based configs & ISR settings for Streams apps

[ https://issues.apache.org/jira/browse/KAFKA-8913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934877#comment-16934877 ] ASF GitHub Bot commented on KAFKA-8913: --- vinothchandar commented on pull request #2

[jira] [Updated] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to emit events after 24h

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8924: - Labels: needs-kip (was: ) > Default grace period (-1) of TimeWindows causes suppress to emit eve