Kafka Emulator CLI: Record and Reply Records considering time-distance

Posted on
poc kafka cli tools

Looking for alternative ways to reproduce time-based conditions in Kafka Streams applications —e.g. if you’re doing some sort of join or windowing based on time— I ended up creating a CLI tool to support a couple of features:

  • Record events from topics, including their timestamps and gap
  • Replay events, including waiting periods between them

SQLite is used a storage for recorded events, so events can be generated, updated, tweaked using SQL.

For more information: