onyx.tasks.kafka — org.onyxplatform/onyx-kafka 0.13.5.0

consumer clj

(consumer task-name opts)

(consumer task-name
          topic
          group-id
          zookeeper
          offset-reset
          deserializer-fn
          task-opts)

Inputs: ([task-name :- s/Keyword opts] [task-name :- s/Keyword topic :- s/Str group-id :- s/Str zookeeper :- s/Str offset-reset :- (s/enum :earliest :latest) deserializer-fn :- os/NamespacedKeyword task-opts :- #:s{Any s/Any}])

deserialize-message-edn clj

(deserialize-message-edn bs)

deserialize-message-json clj

(deserialize-message-json bs)

KafkaInputTaskMap clj

KafkaOutputTaskMap clj

producer clj

(producer task-name opts)

(producer task-name topic zookeeper serializer-fn request-size task-opts)

Inputs: ([task-name :- s/Keyword opts] [task-name :- s/Keyword topic :- s/Str zookeeper :- s/Str serializer-fn :- os/NamespacedKeyword request-size :- s/Num task-opts :- #:s{Any s/Any}])

serialize-message-edn clj

(serialize-message-edn segment)

serialize-message-json clj

(serialize-message-json segment)