Search code examples
apache-kafkakafka-consumer-apiapache-kafka-streamsconfluent-platform

KTable from a topic and service restart

I am confused so asking this question here.

  1. Create a Ktable K1 from a Kafka topic T1. Read from offset 0 to offset latest.
  2. Topic T1 is produced by someother service, here it is consumed only to create KTable K1
  3. I restart my service
  4. I understand the Ktable K1 will be recreated and my question is

Q. Will the KTable K1 have all data from topic T1 again or the table consumer will preserve the offset and ignore the already consumed messages from Topic T1?

Solution

  • KTable K1 will have all data from topic T1.