kafka-metamorphosis.java.kafka-consumer-wrapper

Liking cljdoc? Tell your friends :D

Clojure only.

kcw-close
kcw-consume
kcw-init
kcw-poll
kcw-stop
kcw-subscribe

Java-facing wrapper around kafka-metamorphosis.consumer.

Emits io.github.caioclavico.kafkametamorphosis.KafkaConsumerWrapper.

Java usage:

try (KafkaConsumerWrapper c = new KafkaConsumerWrapper("orders-group")) { c.subscribe(List.of("orders.new")); c.consume(1000L, record -> { System.out.println(record.value()); }); }

Java-facing wrapper around kafka-metamorphosis.consumer.

Emits io.github.caioclavico.kafkametamorphosis.KafkaConsumerWrapper.

Java usage:

  try (KafkaConsumerWrapper c =
           new KafkaConsumerWrapper("orders-group")) {
      c.subscribe(List.of("orders.new"));
      c.consume(1000L, record -> {
          System.out.println(record.value());
      });
  }

raw docstring