[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16878674#comment-16878674
]
Di Campo commented on KAFKA-5998:
-
My topology contains stateless subtopologies, so it ma
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16878674#comment-16878674
]
Di Campo edited comment on KAFKA-5998 at 7/4/19 1:55 PM:
-
My topo
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16880482#comment-16880482
]
Di Campo commented on KAFKA-5998:
-
Thanks Patrik.
So, if for some reason an application i
[
https://issues.apache.org/jira/browse/KAFKA-8612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16891712#comment-16891712
]
Di Campo commented on KAFKA-8612:
-
I've upgraded to 2.3 in testing environment and for a
[
https://issues.apache.org/jira/browse/KAFKA-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16891715#comment-16891715
]
Di Campo commented on KAFKA-8608:
-
Hi Lillian,
I'm afraid I can't, If it happens again,
[
https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16940802#comment-16940802
]
Di Campo commented on KAFKA-8770:
-
This comes from the following use case:
Relation betw
[
https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17148801#comment-17148801
]
Di Campo commented on KAFKA-4273:
-
Any news or improved workaround? I am also interested
[
https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17148801#comment-17148801
]
Di Campo edited comment on KAFKA-4273 at 6/30/20, 4:12 PM:
---
Any
[
https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17152866#comment-17152866
]
Di Campo edited comment on KAFKA-4273 at 7/7/20, 4:27 PM:
--
Thank
[
https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17152866#comment-17152866
]
Di Campo commented on KAFKA-4273:
-
Thanks Matthias.
In my case I want an emit-on-change
[
https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17152866#comment-17152866
]
Di Campo edited comment on KAFKA-4273 at 7/7/20, 4:27 PM:
--
Thank
[
https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17152866#comment-17152866
]
Di Campo edited comment on KAFKA-4273 at 7/7/20, 4:28 PM:
--
Thank
[
https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153365#comment-17153365
]
Di Campo commented on KAFKA-4273:
-
Just tried it, and WindowStoreIterator.remove is an un
[
https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153365#comment-17153365
]
Di Campo edited comment on KAFKA-4273 at 7/8/20, 8:56 AM:
--
Just
[
https://issues.apache.org/jira/browse/KAFKA-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318130#comment-17318130
]
Di Campo commented on KAFKA-8165:
-
Thanks A. Sophie.
Yes, it was OK to close the ticket.
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
[
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 tas
[
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
was:
[
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 appli
[
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 stateful)
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814233#comment-16814233
]
Di Campo commented on KAFKA-5998:
-
It also happens to me on kafka_2.12-2.1.0. Run in AWS
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814233#comment-16814233
]
Di Campo edited comment on KAFKA-5998 at 4/10/19 9:13 AM:
--
It al
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814233#comment-16814233
]
Di Campo edited comment on KAFKA-5998 at 4/10/19 9:13 AM:
--
It al
[
https://issues.apache.org/jira/browse/KAFKA-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850739#comment-16850739
]
Di Campo commented on KAFKA-8165:
-
Some things we did to help:
- Allocating more memory
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
Proje
[
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 & Cach
[
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 t
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
[
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 appli
[
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 appli
[
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 appli
[
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 appli
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877136#comment-16877136
]
Di Campo commented on KAFKA-5998:
-
Just in case it helps. I just found it today on 2.1.1
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877136#comment-16877136
]
Di Campo edited comment on KAFKA-5998 at 7/2/19 4:52 PM:
-
Just in
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 Fe
[
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 f
[
https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16494982#comment-16494982
]
Di Campo commented on KAFKA-6188:
-
Hi ,
I faced same issue as [~chubao] when deleting a
[
https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16494982#comment-16494982
]
Di Campo edited comment on KAFKA-6188 at 6/2/18 6:18 PM:
-
Hi ,
I
38 matches
Mail list logo