Neha, welcome to the community. I assume you are using Kafka Streams to build your application? For this case, the _result_ of a join is not stored in a local state store and there is also no changelog topic for the result.
Only the inputs to the join would be put into local state stores. It depends on what join you actually use (stream-stream, stream-table, table-table) what configurations you can apply to those stores. -Matthias On 1/29/20 7:31 AM, Neha Jha wrote: > Hi everyone, > I am new to the Kafka community and learning the ropes here. I have an app > in which there is a join of two topics. From what I understand, after the > join the data is stored in local store and change-log topic. > Now, the data in local store and change-log topics is deleted only after > retention period. I want to manually delete the data in local store and > change-log topic after producing the data in output topic to prevent memory > usage in case of replays. > > Is it possible to do so? > > Thanks >
signature.asc
Description: OpenPGP digital signature
