Hi John,
Can you please point us to code where Thread-2 will be able to recreate the
state directory once cleaner is done ?
Also, we see that in https://issues.apache.org/jira/browse/KAFKA-6122, retries
around locks is removed. Please let us know why retry mechanism is removed?
Also can you pl
We are using kakfa streams version 1.1.0
We made some changes to kafka streams code. We are observing following sequence
of events in our production environment. We want to understand if following
sequence of events is possible in 1.1.0 version also.
time T0
StreamThread-1 : got assigned 0_1,
Hi John,
i see in https://github.com/apache/kafka/pull/3653
there is discussion around swallowing of LockException and retry not being
there.
but dguy replied saying that "The retry doesn't happen in this block of code.
It will happen the next time the runLoop executes."
but state of thread is
Hi John,
i see in https://github.com/apache/kafka/pull/3653
there is discussion around swallowing of LockException and retry not being
there.
but dguy replied saying that "The retry doesn't happen in this block of code.
It will happen the next time the runLoop executes."
but state of thread is
[
https://issues.apache.org/jira/browse/KAFKA-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Giridhar Addepalli resolved KAFKA-6645.
---
Resolution: Information Provided
> Host Affinity to facilitate faster restarts
Giridhar Addepalli created KAFKA-6645:
-
Summary: Sticky Partition Assignment across Kafka Streams
application restarts
Key: KAFKA-6645
URL: https://issues.apache.org/jira/browse/KAFKA-6645
