Looking back at the ksql-stream logs: I find for a query I'm trying to terminate this line:
[2020-04-17 09:17:52,502] INFO stream-client [_confluent-ksql-default_query_CSAS_PROD_GTEL_AFA_GOL_PREV_GARANZIE_INTERNAL_AVRO_180-2625ef40-c00a-4cdf-98ea-df239aa2f29d] *Already in the pending shutdown state*, wait to complete shutdown (org.apache.kafka.streams.KafkaStreams:849) and it just stays there, without any more information. Restarting the server apparently doesn't help. Il giorno ven 17 apr 2020 alle ore 11:07 Federico D'Ambrosio < fedex...@gmail.com> ha scritto: > Hi, > > We deployed 30-something queries which convert json events to avro, but > lately I've noticed some of the queries are consuming very slowly, > accumulating quite a bit of lag. > In order to reset those streams, I tried to terminate those queries, to > then recreate the streams, but the TERMINATE command from KSQL cli just > hangs without any feedback. > > Ksql log is not much helpful, really just showing the POST request being > sent. > > How should we proceed? Is there anyway to force deletion of a > query/stream? > What could be causing this issue? > > Thank you, > Federico D'Ambrosio > -- Federico D'Ambrosio
