Kafka Strategies

Delayed Consumer

Consumer Pseudo

msg := readKafka("orders.delayed")
if msg.process_after > time.Now() {
  sleep(msg.process_after - time.Now())
}
process(msg.data)

Double Queue Instant Ack