[jira] [Commented] (KAFKA-5636) DSL: allow sliding windows to be used directly (i.e. not just implicitly when doing joins)

[ https://issues.apache.org/jira/browse/KAFKA-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816774#comment-16816774 ] ASF GitHub Bot commented on KAFKA-5636: --- ableegoldman commented on pull request #6549: KAFKA-5636:

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816770#comment-16816770 ] Guozhang Wang commented on KAFKA-5998: -- Thank you guys! I will run over those info and get back to

[jira] [Assigned] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8187: -- Assignee: Bill Bejeck > State store record loss across multiple reassignments when using

[jira] [Commented] (KAFKA-8213) KStreams interactive query documentation typo

[ https://issues.apache.org/jira/browse/KAFKA-8213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816738#comment-16816738 ] ASF GitHub Bot commented on KAFKA-8213: --- londoncalling commented on pull request #201: KAFKA-8213

[jira] [Commented] (KAFKA-8212) KStreams documentation Maven artifact table is cut off

[ https://issues.apache.org/jira/browse/KAFKA-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816734#comment-16816734 ] ASF GitHub Bot commented on KAFKA-8212: --- londoncalling commented on pull request #6576: KAFKA-8212

[jira] [Commented] (KAFKA-8212) KStreams documentation Maven artifact table is cut off

[ https://issues.apache.org/jira/browse/KAFKA-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816729#comment-16816729 ] ASF GitHub Bot commented on KAFKA-8212: --- londoncalling commented on pull request #200: KAFKA-8212

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816689#comment-16816689 ] Bill Bejeck commented on KAFKA-7965: failed again 

[jira] [Commented] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816676#comment-16816676 ] Bill Bejeck commented on KAFKA-8187: Hi, [~wgreerx] just touching base to see if you are interested

[jira] [Comment Edited] (KAFKA-3705) Support non-key joining in KTable

[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816656#comment-16816656 ] Adam Bellemare edited comment on KAFKA-3705 at 4/12/19 9:05 PM: The PR is

[jira] [Commented] (KAFKA-3705) Support non-key joining in KTable

[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816656#comment-16816656 ] Adam Bellemare commented on KAFKA-3705: --- The PR is now in a draft state - there are a few issues

[jira] [Commented] (KAFKA-8213) KStreams interactive query documentation typo

[ https://issues.apache.org/jira/browse/KAFKA-8213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816597#comment-16816597 ] ASF GitHub Bot commented on KAFKA-8213: --- londoncalling commented on pull request #6574: KAFKA-8213

[jira] [Updated] (KAFKA-8204) Streams may flush state stores in the incorrect order

[ https://issues.apache.org/jira/browse/KAFKA-8204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-8204: Fix Version/s: 2.0.2 1.1.2 > Streams may flush state stores in the incorrect

[jira] [Commented] (KAFKA-8204) Streams may flush state stores in the incorrect order

[ https://issues.apache.org/jira/browse/KAFKA-8204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816561#comment-16816561 ] John Roesler commented on KAFKA-8204: - Thanks [~mjsax]. Actually, in the code review, [~guozhang]

[jira] [Updated] (KAFKA-8204) Streams may flush state stores in the incorrect order

[ https://issues.apache.org/jira/browse/KAFKA-8204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-8204: Affects Version/s: (was: 1.0.2) (was: 0.11.0.3)

[jira] [Commented] (KAFKA-8210) Missing link for KStreams in Streams DSL docs

[ https://issues.apache.org/jira/browse/KAFKA-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816473#comment-16816473 ] ASF GitHub Bot commented on KAFKA-8210: --- bbejeck commented on pull request #6573: KAFKA-8210: Fix

[jira] [Created] (KAFKA-8227) Missing Links in Duality of Streams and Tables section

Bill Bejeck created KAFKA-8227: -- Summary: Missing Links in Duality of Streams and Tables section Key: KAFKA-8227 URL: https://issues.apache.org/jira/browse/KAFKA-8227 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-8210) Missing link for KStreams in Streams DSL docs

[ https://issues.apache.org/jira/browse/KAFKA-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816437#comment-16816437 ] ASF GitHub Bot commented on KAFKA-8210: --- bbejeck commented on pull request #199: KAFKA-8210: Fix

[jira] [Commented] (KAFKA-8208) Broken link for out-of-order data in KStreams Core Concepts doc

[ https://issues.apache.org/jira/browse/KAFKA-8208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816380#comment-16816380 ] ASF GitHub Bot commented on KAFKA-8208: --- bbejeck commented on pull request #6572: KAFKA-8208:

[jira] [Commented] (KAFKA-8148) Kafka Group deletion

[ https://issues.apache.org/jira/browse/KAFKA-8148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816349#comment-16816349 ] Atul T Renapurkar commented on KAFKA-8148: -- It is expecting zookeeper port only. > Kafka Group

[jira] [Comment Edited] (KAFKA-8207) StickyPartitionAssignor for KStream

[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816210#comment-16816210 ] neeraj edited comment on KAFKA-8207 at 4/12/19 12:26 PM: - StreamPartitionAssignor

[jira] [Commented] (KAFKA-8207) StickyPartitionAssignor for KStream

[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816210#comment-16816210 ] neeraj commented on KAFKA-8207: --- StreamPartitionAssignor sticky policy is for the stickiness of Tasks to

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816157#comment-16816157 ] Tom Wells commented on KAFKA-5998: -- Hi all - I've been running into this same issue for the past few

[jira] [Commented] (KAFKA-7866) Duplicate offsets after transaction index append failure

[ https://issues.apache.org/jira/browse/KAFKA-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816120#comment-16816120 ] ASF GitHub Bot commented on KAFKA-7866: --- hachikuji commented on pull request #6570: KAFKA-7866;

[jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean (Windows OS)

[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816099#comment-16816099 ] ASF GitHub Bot commented on KAFKA-6647: --- jukkakarvanen commented on pull request #6569: KAFKA-6647

[jira] [Updated] (KAFKA-8226) New MirrorMaker option partition.to.partition

[ https://issues.apache.org/jira/browse/KAFKA-8226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ernestas Vaiciukevičius updated KAFKA-8226: --- Description: Currently when MirrorMaker moves data between topics with

[jira] [Created] (KAFKA-8226) New MirrorMaker option partition.to.partition

Ernestas Vaiciukevičius created KAFKA-8226: -- Summary: New MirrorMaker option partition.to.partition Key: KAFKA-8226 URL: https://issues.apache.org/jira/browse/KAFKA-8226 Project: Kafka

[jira] [Commented] (KAFKA-7601) Handle message format downgrades during upgrade of message format version

[ https://issues.apache.org/jira/browse/KAFKA-7601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816022#comment-16816022 ] ASF GitHub Bot commented on KAFKA-7601: --- hachikuji commented on pull request #6568: KAFKA-7601;

[jira] [Commented] (KAFKA-7791) Not log retriable exceptions as errors

[ https://issues.apache.org/jira/browse/KAFKA-7791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816018#comment-16816018 ] Andrzej Ludwikowski commented on KAFKA-7791: Hello, any progress on this issue?  > Not log