I think if you just log to the console, kubernetes will manage the log
rotation for you.
https://kubernetes.io/docs/concepts/cluster-administration/logging/
You can use "kubectl logs" command to fetch the logs or use some logging
agent to move the logs centrally.
On Tue, Aug 4, 2020 at 8:15 PM Sri
You can try to convert the final resultant stream to table.
Check this page for more info:
https://docs.confluent.io/current/streams/faq.html#how-can-i-convert-a-kstream-to-a-ktable-without-an-aggregation-step
This way table would always contain the latest (single) record for a given
key.
Sachin
Sachin Mittal created KAFKA-4848:
Summary: Stream thread getting into deadlock state while trying to
get rocksdb lock in retryWithBackoff
Key: KAFKA-4848
URL: https://issues.apache.org/jira/browse/KAFKA-4848
[
https://issues.apache.org/jira/browse/KAFKA-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15897462#comment-15897462
]
Sachin Mittal commented on KAFKA-4848:
--
The deadlock issue is like this.
If a th
[
https://issues.apache.org/jira/browse/KAFKA-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15897463#comment-15897463
]
Sachin Mittal commented on KAFKA-4848:
--
Please refer https://github.com/apache/k
[
https://issues.apache.org/jira/browse/KAFKA-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935744#comment-15935744
]
Sachin Mittal commented on KAFKA-4848:
--
[~guozhang] We ran only once instanc
[
https://issues.apache.org/jira/browse/KAFKA-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15953777#comment-15953777
]
Sachin Mittal commented on KAFKA-4848:
--
Please let me know if this will be don
