Re: KStreams State Store - state.dir does not have .checkpoint file

> On Jun 1, 2022, at 5:27 AM, Neeraj Vaidya > wrote: > > Thanks John ! > It seems if I send a TERM signal to my KStreams application which is running > inside a Docker container, then it results in a Clean shutdown. > This also then creates a checkpoint file successfully. > So, I guess I need

Kafka as a service

Hi everyone, I run Kafka server as a service on Linux with the following settings: [Unit] Description=Kafka [Service] Type=simple Restart=on-abnormal User=svc_kafka ExecStart=/app/kafka/kafka_2.13-3.1.0/bin/kafka-server-start.sh /app/kafka/kafka_2.13-3.1.0/config/server.properties ExecStop=/app

Re: KStreams State Store - state.dir does not have .checkpoint file

Thanks John ! It seems if I send a TERM signal to my KStreams application which is running inside a Docker container, then it results in a Clean shutdown. This also then creates a checkpoint file successfully. So, I guess I need to figure out how to send a TERM signal to my running Java KStreams