Internal helpers for the Java-facing facade. NOT part of the public API. Centralizes type-coercion between Java collections and Clojure data so the individual gen-class wrappers stay small and free of reflection.
Internal helpers for the Java-facing facade. NOT part of the public API. Centralizes type-coercion between Java collections and Clojure data so the individual gen-class wrappers stay small and free of reflection.
Java-facing wrapper around kafka-metamorphosis.admin.
Emits io.github.caioclavico.kafkametamorphosis.KafkaAdminWrapper.
Java-facing wrapper around kafka-metamorphosis.admin. Emits io.github.caioclavico.kafkametamorphosis.KafkaAdminWrapper.
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());
});
}Java-facing wrapper around kafka-metamorphosis.producer.
Emits the concrete class io.github.caioclavico.kafkametamorphosis.KafkaProducerWrapper via :gen-class. Java callers use it as any normal Java class:
try (KafkaProducerWrapper p = new KafkaProducerWrapper()) { p.publish("orders.new", "123", "{"ticker":"PETR4"}"); }
No clojure.java.api.Clojure, no IFn.invoke, no reflection on the Java side.
Java-facing wrapper around kafka-metamorphosis.producer.
Emits the concrete class
io.github.caioclavico.kafkametamorphosis.KafkaProducerWrapper
via :gen-class. Java callers use it as any normal Java class:
try (KafkaProducerWrapper p = new KafkaProducerWrapper()) {
p.publish("orders.new", "123", "{\"ticker\":\"PETR4\"}");
}
No clojure.java.api.Clojure, no IFn.invoke, no reflection on the
Java side.cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |