Bookmark this page

Summary

In this chapter, you learned:

  • Different notions of time exist in Kafka Streams: event time, processing time, and ingestion time.

  • Windowing operations allow developers to group events in time.

  • Kafka Streams can handle late events by using grace periods.

  • Idempotent Kafka producers prevent potential duplicates caused by retries.

  • Kafka consumers can deactivate the autocommit feature and use transactions to prevent data loss and duplication.

  • Kafka Streams test utils provides methods to unit test topologies in isolation.

Revision: ad482-1.8-cc2ae1c