fr33m0nk.alpakka-kafka.producer — net.clojars.fr33m0nk/clj-alpakka-kafka 0.1.3

Akka Stream connector for publishing messages to Kafka topics

->producer-record clj

(->producer-record topic value)

(->producer-record topic value key)

(->producer-record topic value key partition-number)

(->producer-record topic value key partition-number timestamp-as-long headers)

creates a producer record which can be used later for publishing

->send-producer clj

(->send-producer producer-settings actor-system)

Utility Kafka Producer for producing to Kafka without using Akka Streams. https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/javadsl/SendProducer.html

close-send-producer clj

(close-send-producer send-producer)

https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/javadsl/SendProducer.html#close():java.util.concurrent.CompletionStage[akka.Done]

committable-sink clj

(committable-sink producer-settings committer-settings)

https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/javadsl/Producer$.html#committableSinkK,V,IN%3C:akka.kafka.ProducerMessage.Envelope[K,V,akka.kafka.ConsumerMessage.Committable]:akka.stream.javadsl.Sink[IN,java.util.concurrent.CompletionStage[akka.Done]]

committable-sink-with-offset-context clj

(committable-sink-with-offset-context producer-settings committer-settings)

https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/javadsl/Producer$.html#committableSinkWithOffsetContextK,V,IN%3C:akka.kafka.ProducerMessage.Envelope[K,V,_],C%3C:akka.kafka.ConsumerMessage.Committable:akka.stream.javadsl.Sink[akka.japi.Pair[IN,C],java.util.concurrent.CompletionStage[akka.Done]]

flexi-flow clj

(flexi-flow producer-settings)

Akka Stream connector for publishing messages to Kafka topics. https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/javadsl/Producer$.html#flexiFlowK,V,PassThrough:akka.stream.javadsl.Flow[akka.kafka.ProducerMessage.Envelope[K,V,PassThrough],akka.kafka.ProducerMessage.Results[K,V,PassThrough],akka.NotUsed]

flow-with-context clj

(flow-with-context producer-settings)

https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/javadsl/Producer$.html#flowWithContextK,V,C:akka.stream.javadsl.FlowWithContext[akka.kafka.ProducerMessage.Envelope[K,V,akka.NotUsed],C,akka.kafka.ProducerMessage.Results[K,V,C],C,akka.NotUsed]

IProducerMessage clj protocol

PassThroughMessage does not publish anything, and continues in the stream as PassThroughResult

producer-message-passthrough clj

(producer-message-passthrough this)

https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/ProducerMessage$$Envelope.html#passThrough:PassThrough

producer-message-with-passthrough clj

(producer-message-with-passthrough this passthrough)

https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/ProducerMessage$$Envelope.html#withPassThroughPassThrough2:akka.kafka.ProducerMessage.Envelope[K,V,PassThrough2]

multi-producer-message-envelope clj

(multi-producer-message-envelope message-offset producer-records)

MultiMessage publishes all messages in its records field, and continues in the stream as MultiResult https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/ProducerMessage$$MultiMessage.html

plain-sink clj

(plain-sink producer-settings)

https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/javadsl/Producer$.html#plainSinkK,V:akka.stream.javadsl.Sink[org.apache.kafka.clients.producer.ProducerRecord[K,V],java.util.concurrent.CompletionStage[akka.Done]]

producer-settings clj

(producer-settings actor-system
                   {:keys [key-serializer value-serializer bootstrap-servers]
                    :as producer-properties})

Settings for producers. See akka.kafka.producer section in reference.conf https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/ProducerSettings.html

• Expects producer-properties to be supplied with kebab-case-keyword keys Full config list can be found in org.apache.kafka.clients.producer.ProducerConfig

publish-via-send-producer clj

(publish-via-send-producer send-producer producer-record)

https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/javadsl/SendProducer.html#send(record:org.apache.kafka.clients.producer.ProducerRecord[K,V]):java.util.concurrent.CompletionStage[org.apache.kafka.clients.producer.RecordMetadata]

single-producer-message-envelope clj

(single-producer-message-envelope message-offset producer-record)

Message publishes a single message to its topic, and continues in the stream as Result https://doc.akka.io/api/alpakka-kafka/4.0.2/akka/kafka/ProducerMessage$$Message.html