Developing Event-driven Applications with Apache Kafka and Red Hat AMQ Streams
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
autocommitfeature and use transactions to prevent data loss and duplication.Kafka Streams test utils provides methods to unit test topologies in isolation.
Lab Controls
Click CREATE to build all of the virtual machines needed for the classroom lab environment. This may take several minutes to complete. Once created the environment can then be stopped and restarted to pause your experience.
If you DELETE your lab, you will remove all of the virtual machines in your classroom and lose all of your progress.