com.flocktory.protocol.config — com.flocktory/kafka-consumer 0.0.6

IKafkaConsumerConfig clj protocol

kafka-consumer-config clj

(kafka-consumer-config this)

Returns map with any keys from org.apache.kafka.clients.consumer.ConsumerConfig. ConsumerConfig/GROUP_ID_CONFIG key is required.

Example: {ConsumerConfig/GROUP_ID_CONFIG "some-group-id" ConsumerConfig/AUTO_OFFSET_RESET_CONFIG "latest"}

Or strings as keys: {"group.id" "some-group-id" "max.poll.records" 100}

See defaults in KAFKA_CONSUMER_CONFIG_DEFAULTS.

IOptionalConfig clj protocol

Optional configuration protocol

optional-config clj

(optional-config this)

Returns map with any of keys:

:value-format - available formats to decode record value from (:json), no decoding if nil :poll-timeout-ms - kafka poll timeout :min-commit-interval-ms - minimal interval between commits

Example: {:poll-timeout-ms 1000 :value-format nil}

See defaults in OPTIONAL_CONFIG_DEFAULTS

ITopics clj protocol

topics clj

(topics this)

List of topics (one or more) to subscribe.

Example: ["topic1" "topic2"]

KAFKA_CONSUMER_CONFIG_DEFAULTS clj

OPTIONAL_CONFIG_DEFAULTS clj