[jira] [Commented] (KAFKA-8165) Streams task causes Out Of Memory after connection issues and store restoration

2021-04-09 Thread Di Campo (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318130#comment-17318130 ] Di Campo commented on KAFKA-8165: - Thanks A. Sophie. Yes, it was OK to close the ticket. > Streams

[jira] [Comment Edited] (KAFKA-4273) Streams DSL - Add TTL / retention period support for intermediate topics and state stores

2020-07-08 Thread Di Campo (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153365#comment-17153365 ] Di Campo edited comment on KAFKA-4273 at 7/8/20, 8:56 AM: -- Just tried it, and

[jira] [Commented] (KAFKA-4273) Streams DSL - Add TTL / retention period support for intermediate topics and state stores

2020-07-08 Thread Di Campo (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153365#comment-17153365 ] Di Campo commented on KAFKA-4273: - Just tried it, and WindowStoreIterator.remove is an unsupported

[jira] [Comment Edited] (KAFKA-4273) Streams DSL - Add TTL / retention period support for intermediate topics and state stores

2020-07-07 Thread Di Campo (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17152866#comment-17152866 ] Di Campo edited comment on KAFKA-4273 at 7/7/20, 4:28 PM: -- Thanks Matthias. In

[jira] [Comment Edited] (KAFKA-4273) Streams DSL - Add TTL / retention period support for intermediate topics and state stores

2020-07-07 Thread Di Campo (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17152866#comment-17152866 ] Di Campo edited comment on KAFKA-4273 at 7/7/20, 4:27 PM: -- Thanks Matthias. In

[jira] [Commented] (KAFKA-4273) Streams DSL - Add TTL / retention period support for intermediate topics and state stores

2020-07-07 Thread Di Campo (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17152866#comment-17152866 ] Di Campo commented on KAFKA-4273: - Thanks Matthias. In my case I want an emit-on-change behaviour, so

[jira] [Comment Edited] (KAFKA-4273) Streams DSL - Add TTL / retention period support for intermediate topics and state stores

2020-07-07 Thread Di Campo (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17152866#comment-17152866 ] Di Campo edited comment on KAFKA-4273 at 7/7/20, 4:27 PM: -- Thanks Matthias. In

[jira] [Comment Edited] (KAFKA-4273) Streams DSL - Add TTL / retention period support for intermediate topics and state stores

2020-06-30 Thread Di Campo (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148801#comment-17148801 ] Di Campo edited comment on KAFKA-4273 at 6/30/20, 4:12 PM: --- Any news or

[jira] [Commented] (KAFKA-4273) Streams DSL - Add TTL / retention period support for intermediate topics and state stores

2020-06-30 Thread Di Campo (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148801#comment-17148801 ] Di Campo commented on KAFKA-4273: - Any news or improved workaround? I am also interested on this.  In my

[jira] [Commented] (KAFKA-8770) Either switch to or add an option for emit-on-change

2019-09-30 Thread Di Campo (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940802#comment-16940802 ] Di Campo commented on KAFKA-8770: - This comes from the following use case: Relation between pageview and

[jira] [Commented] (KAFKA-8608) Broker shows WARN on reassignment partitions on new brokers: Replica LEO, follower position & Cache truncation

2019-07-24 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891715#comment-16891715 ] Di Campo commented on KAFKA-8608: - Hi Lillian, I'm afraid I can't, If it happens again, which context do

[jira] [Commented] (KAFKA-8612) Broker removes consumers from CG, Streams app gets stuck

2019-07-24 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891712#comment-16891712 ] Di Campo commented on KAFKA-8612: - I've upgraded to 2.3 in testing environment and for a week it hasn't

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

2019-07-08 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880482#comment-16880482 ] Di Campo commented on KAFKA-5998: - Thanks Patrik. So, if for some reason an application is stopped for

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

2019-07-04 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878674#comment-16878674 ] Di Campo commented on KAFKA-5998: - My topology contains stateless subtopologies, so it may be that case. 

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

2019-07-04 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878674#comment-16878674 ] Di Campo edited comment on KAFKA-5998 at 7/4/19 1:55 PM: - My topology contains

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

2019-07-02 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877136#comment-16877136 ] Di Campo edited comment on KAFKA-5998 at 7/2/19 4:52 PM: - Just in case it helps.

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

2019-07-02 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877136#comment-16877136 ] Di Campo commented on KAFKA-5998: - Just in case it helps. I just found it today on 2.1.1 (again, I

[jira] [Updated] (KAFKA-8612) Broker removes consumers from CG, Streams app gets stuck

2019-06-28 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8612: Description: Cluster of 5 brokers, `Kafka 2.1.1`. m5.large (2 CPU, 8GB RAM) instances. Kafka Streams

[jira] [Updated] (KAFKA-8612) Broker removes consumers from CG, Streams app gets stuck

2019-06-28 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8612: Description: Cluster of 5 brokers, `Kafka 2.1.1`. m5.large (2 CPU, 8GB RAM) instances. Kafka Streams

[jira] [Updated] (KAFKA-8612) Broker removes consumers from CG, Streams app gets stuck

2019-06-28 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8612: Description: Cluster of 5 brokers, `Kafka 2.1.1`. m5.large (2 CPU, 8GB RAM) instances. Kafka Streams

[jira] [Updated] (KAFKA-8612) Broker removes consumers from CG, Streams app gets stuck

2019-06-28 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8612: Description: Cluster of 5 brokers, `Kafka 2.1.1`. m5.large (2 CPU, 8GB RAM) instances. Kafka Streams

[jira] [Created] (KAFKA-8612) Broker removes consumers from CG, Streams app gets stuck

2019-06-28 Thread Di Campo (JIRA)
Di Campo created KAFKA-8612: --- Summary: Broker removes consumers from CG, Streams app gets stuck Key: KAFKA-8612 URL: https://issues.apache.org/jira/browse/KAFKA-8612 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-8608) Broker shows WARN on reassignment partitions on new brokers: Replica LEO, follower position & Cache truncation

2019-06-28 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8608: Description: I added two brokers (brokerId 4,5) to a 3-node (brokerId 1,2,3) cluster where there were 32

[jira] [Updated] (KAFKA-8608) Broker shows WARN on reassignment partitions on new brokers: Replica LEO, follower position & Cache truncation

2019-06-28 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8608: Summary: Broker shows WARN on reassignment partitions on new brokers: Replica LEO, follower position &

[jira] [Created] (KAFKA-8608) Broker shows WARN on reassignment partitions on new brokers: Replica LEO & Cache truncation

2019-06-27 Thread Di Campo (JIRA)
Di Campo created KAFKA-8608: --- Summary: Broker shows WARN on reassignment partitions on new brokers: Replica LEO & Cache truncation Key: KAFKA-8608 URL: https://issues.apache.org/jira/browse/KAFKA-8608

[jira] [Commented] (KAFKA-8165) Streams task causes Out Of Memory after connection issues and store restoration

2019-05-29 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16850739#comment-16850739 ] Di Campo commented on KAFKA-8165: - Some things we did to help:  - Allocating more memory - Reducing

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

2019-04-10 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814233#comment-16814233 ] Di Campo edited comment on KAFKA-5998 at 4/10/19 9:13 AM: -- It also happens to me

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

2019-04-10 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814233#comment-16814233 ] Di Campo commented on KAFKA-5998: - It also happens to me on kafka_2.12-2.1.0. Run in AWS in docker (based

[jira] [Updated] (KAFKA-8165) Streams task causes Out Of Memory after connection issues and store restoration

2019-03-28 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8165: Description: Having a Kafka Streams 2.1 application, when Kafka brokers are stable, the (largely

[jira] [Updated] (KAFKA-8165) Streams task causes Out Of Memory after connection issues and store restoration

2019-03-28 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8165: Environment: 3 nodes, 22 topics, 16 partitions per topic, 1 window store, 4 KV stores. Kafka Streams

[jira] [Updated] (KAFKA-8165) Streams task causes Out Of Memory after connection and store restoration

2019-03-27 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8165: Environment: Kafka 2.1, Kafka Streams 2.1 Amazon Linux, on Docker based on wurstmeister/kafka image

[jira] [Updated] (KAFKA-8165) Streams task causes Out Of Memory after connection issues and store restoration

2019-03-27 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8165: Summary: Streams task causes Out Of Memory after connection issues and store restoration (was: Streams

[jira] [Created] (KAFKA-8165) Streams task causes Out Of Memory after connection and store restoration

2019-03-27 Thread Di Campo (JIRA)
Di Campo created KAFKA-8165: --- Summary: Streams task causes Out Of Memory after connection and store restoration Key: KAFKA-8165 URL: https://issues.apache.org/jira/browse/KAFKA-8165 Project: Kafka

[jira] [Updated] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore

2018-11-13 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-7622: Description: When creating a session store from the DSL, and you get a  {{ReadOnlySessionStore}}, you can

[jira] [Created] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore

2018-11-13 Thread Di Campo (JIRA)
Di Campo created KAFKA-7622: --- Summary: Add findSessions functionality to ReadOnlySessionStore Key: KAFKA-7622 URL: https://issues.apache.org/jira/browse/KAFKA-7622 Project: Kafka Issue Type: New

[jira] [Comment Edited] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

2018-06-02 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494982#comment-16494982 ] Di Campo edited comment on KAFKA-6188 at 6/2/18 6:18 PM: - Hi , I faced same

[jira] [Commented] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

2018-05-30 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494982#comment-16494982 ] Di Campo commented on KAFKA-6188: - Hi , I faced same issue as [~chubao] when deleting a KafkaStreams