kafka-metamorphosis.streams — org.clojars.caioclavico/kafka-metamorphosis 0.4.8

Kafka Streams wrapper for Kafka Metamorphosis.

branch clj

(branch stream predicates)

Split a KStream into multiple streams using a sequence of predicate functions. Returns a vector of KStreams in the same order as predicates.

build-topology clj

(build-topology builder)

Build a Topology from a StreamsBuilder.

clean-up! clj

(clean-up! streams)

Clean up local state for the Kafka Streams instance.

close! clj

(close! streams)

(close! streams timeout-ms)

Close the Kafka Streams instance. Optionally provide a timeout in milliseconds.

create clj

(create topology config)

Create a KafkaStreams instance from an existing Topology and config map.

create-builder clj

(create-builder)

Create a new Kafka Streams builder.

create-from-builder clj

(create-from-builder builder config)

Create a KafkaStreams instance from a StreamsBuilder and config map.

default-application-id clj

Default Kafka Streams application id.

filter-stream clj

(filter-stream stream pred)

Filter records from a KStream using a predicate function of [key value].

map-values clj

(map-values stream f)

Transform the values of a KStream using f.

f receives the current value and should return the transformed value.

start! clj

(start! streams)

Start the Kafka Streams instance.

state clj

(state streams)

Return the current Kafka Streams state.

stream clj

(stream builder topics)

Create a KStream from a builder and a topic or list of topics.

streams-config clj

(streams-config)

(streams-config application-id)

(streams-config application-id overrides)

Create a Kafka Streams configuration map with sensible defaults.

Usage: (streams-config) ; local brokers and default application id (streams-config "my-app") ; custom application id (streams-config "my-app" {:bootstrap-servers "kafka:9092"})

to clj

(to stream topic)

Send a KStream to the given topic and return the same stream.