/multi-kafka

Primary LanguageKotlin

Codacy Badge build with gradle

An example of reactive (non-blocking) program that subscribe to multiple kafka topics

The flow

  • subscribe to multiple topic.
  • buffer by size or time for each stream.
  • combine the buffers to one stream
  • use n threads to process the combined stream
  • unsubscribe from topic (cleanly)

see interface at http://localhost:8080/swagger-ui.html