The cl-rdkafka Reference Manual

Next: , Previous: , Up: (dir)   [Contents][Index]

The cl-rdkafka Reference Manual

This is the cl-rdkafka Reference Manual, version 1.1.0, generated automatically by Declt version 4.0 beta 2 "William Riker" on Wed Jun 15 03:59:39 2022 GMT+0.

Table of Contents


1 Introduction

cl-rdkafka

CircleCI tag license

A Common Lisp client library for Apache Kafka.

The public API is split between two packages:

Documentation for cl-rdkafka/ll can be found in librdkafka/rdkafka.h, and kf is documented under the API section.

Examples

Producer

(ql:quickload '(cl-rdkafka babel))

(let ((producer (make-instance
                 'kf:producer
                 :conf '("bootstrap.servers" "127.0.0.1:9092"
                         "enable.idempotence" "true")
                 :serde #'babel:string-to-octets))
      (messages '(("key-1" "value-1")
                  ("key-2" "value-2"))))
  (loop
     for (k v) in messages
     do (kf:send producer "topic-name" v :key k))

  (kf:flush producer))

Consumer

(ql:quickload '(cl-rdkafka babel))

(let ((consumer (make-instance
                 'kf:consumer
                 :conf '("bootstrap.servers" "127.0.0.1:9092"
                         "group.id" "consumer-group-id"
                         "enable.auto.commit" "false"
                         "auto.offset.reset" "earliest")
                 :serde #'babel:octets-to-string)))
  (kf:subscribe consumer "topic-name")

  (loop
     for message = (kf:poll consumer 2000)
     while message

     for key = (kf:key message)
     for value = (kf:value message)

     collect (list key value)

     do (kf:commit consumer)))

;; => (("key-1" "message-1") ("key-2" "message-2"))

Transactions :sparkles:

Here's an example which atomically:

  1. Consumes a batch of messages from an input topic
  2. Processes the messages by prefixing them with "processed-"
  3. Produces the processed batch to an output topic
(ql:quickload '(cl-rdkafka babel))

(defun get-next-batch (consumer max-batch-size)
  (loop
    with batch = (make-array 0 :adjustable t :fill-pointer 0)

    repeat max-batch-size
    for message = (kf:poll consumer 5000)
    while message
    do (vector-push-extend message batch)

    finally (return batch)))

(defun process-message (message producer output-topic)
  (let ((new-value (format nil "processed-~A" (kf:value message))))
    (kf:send producer output-topic new-value)))

(defun process-batch (consumer producer output-topic)
  (let ((messages (get-next-batch consumer 5)))
    (map nil
         (lambda (message)
           (process-message message producer output-topic))
         messages)
    (kf:send-offsets-to-transaction producer consumer messages 5000)))

(defun rewind-consumer (consumer)
  (let ((committed (kf:committed consumer (kf:assignment consumer) 5000)))
    (flet ((rewind (topic&partition->offset&metadata)
             (let ((topic (caar topic&partition->offset&metadata))
                   (partition (cdar topic&partition->offset&metadata))
                   (offset (cadr topic&partition->offset&metadata)))
               (if (< offset 0)
                   (kf:seek-to-beginning consumer topic partition 5000)
                   (kf:seek consumer topic partition offset 5000)))))
      (map nil #'rewind committed))))

(let ((consumer (make-instance
                 'kf:consumer
                 :conf '("bootstrap.servers" "127.0.0.1:9092"
                         "group.id" "some-group-id"
                         "enable.auto.commit" "false"
                         "auto.offset.reset" "earliest")
                 :serde #'babel:octets-to-string))
      (producer (make-instance
                 'kf:producer
                 :conf '("bootstrap.servers" "127.0.0.1:9092"
                         "transactional.id" "some-transaction-id")
                 :serde #'babel:string-to-octets)))
  (kf:subscribe consumer "some-input-topic")
  (kf:initialize-transactions producer 5000)

  (kf:begin-transaction producer)
  (handler-case
      (progn
        (process-batch consumer producer "some-output-topic")
        (kf:commit-transaction producer 5000))
    (kf:fatal-error (c)
      (error c))
    (condition (c)
      ;; in case of abort, must seek consumer back to its committed offsets
      ;; this is only needed if the consumer object will continue to be used
      ;; after the abort
      (rewind-consumer consumer)
      (kf:abort-transaction producer 5000)
      (error c))))

Contributing and Hacking

PRs and GitHub issues are always welcome :octocat: and feel free to email me with any questions :incoming_envelope:

To run the tests:

$ docker-compose -f ./test/docker-compose.test.yml \
>   up --build --remove-orphans --abort-on-container-exit test

$ docker-compose -f ./test/docker-compose.test.yml down --rmi all
$ docker system prune -fa && docker volume prune -f

To spin up and teardown a dockerized Kafka cluster to hack against:

# start a cluster on 127.0.0.1:9092
$ docker-compose up --build --remove-orphans -d

# tear the cluster down
$ docker-compose down --rmi all

# clean up after yourself
$ docker system prune -fa && docker volume prune -f

API

producer class

A client that produces messages to kafka topics.

make-instance accepts the following keyword args:

Example:

(let ((producer (make-instance
                 'kf:producer
                 :conf '("bootstrap.servers" "127.0.0.1:9092"
                         "enable.idempotence" "true")
                 :serde #'babel:string-to-octets))
      (messages '(("key-1" "value-1")
                  ("key-2" "value-2"))))
  (loop
     for (k v) in messages
     do (kf:send producer "topic-name" v :key k))

  (kf:flush producer))

send

((producer producer) (topic string) value &key key partition headers timestamp)

Asynchronously send a message and return a message future.

If partition is not specified, one is chosen using the topic's partitioner function.

If specified, headers should be an alist mapping strings to byte-vectors.

timestamp is the number of milliseconds since the UTC epoch. If not specified, one will be generated by this call.

May signal partition-error or condition from producer's serde. A store-function restart will be provided if it's a serde condition.


flush

((producer producer))

Block while in-flight messages are sent to kafka cluster.


initialize-transactions

((producer producer) (timeout-ms integer))

Block for up to timeout-ms milliseconds and initialize transactions for producer.

When transactional.id is configured, this method needs to be called exactly once before any other methods on producer.

This method:

  1. Ensures any transactions initiated by previous producer instances with the same transactional.id are completed:

    • If the previous instance had failed with an in-progress transaction, it will be aborted.

    • If the previous transaction had started committing, but had not yet finished, this method waits for it to finish.

  2. Acquires the internal producer id and epoch to use with all future transactional messages sent by producer. This will be used to fence out any previous instances.

May signal a fatal-error, transaction-error, or retryable-operation-error. A retry-operation restart will be provided if it's a retryable-operation-error.


begin-transaction

((producer producer))

Begin a transaction.

initialize-transactions must have been called exactly once before this method, and only one transaction can be in progress at a time for producer.

The transaction can be committed with commit-transaction or aborted with abort-transaction.

May signal fatal-error or transaction-error.


commit-transaction

((producer producer) (timeout-ms integer))

Block for up to timeout-ms milliseconds and commit the ongoing transaction.

A transaction must have been started by begin-transaction.

This method will flush all enqueued messages before issuing the commit. If any of the messages fails to be sent, an abort-required-error will be signalled.

May signal:


abort-transaction

((producer producer) (timeout-ms integer))

Block for up to timeout-ms milliseconds and abort the ongoing transaction.

A transaction must have been started by begin-transaction.

This method will purge all enqueued messages before issuing the abort.

May signal a fatal-error, transaction-error, or retryable-operation-error. A retry-operation and continue restart will be provided if it's a retryable-operation-error.


send-offsets-to-transaction

(producer consumer offsets timeout-ms)

Send offsets to consumer group coordinator and mark them as part of the ongoing transaction.

A transaction must have been started by begin-transaction.

This method will block for up to timeout-ms milliseconds.

offsets should be associated with consumer, and will be considered committed only if the ongoing transaction is committed successfully. Each offset should refer to the next message that the consumer poll method should return: the last processed message's offset + 1. Invalid offsets will be ignored.

consumer should have enable.auto.commit set to false and should not commit offsets itself through the commit method.

This method should be called at the end of a consume->transform->produce cycle, before calling commit-transaction.

May signal:

list specialization

((producer producer) (consumer consumer) (offsets list) (timeout-ms integer))

offsets should be an alist mapping (topic . partition) cons cells to either (offset . metadata) cons cells or lone offset values.

hash-table specialization

((producer producer) (consumer consumer) (offsets hash-table) (timeout-ms integer))

offsets should be a hash-table mapping (topic . partition) cons cells to either (offset . metadata) cons cells or lone offset values.

sequence specialization

((producer producer) (consumer consumer) (offsets sequence) (timeout-ms integer))

offsets should be a sequence of messages processed by consumer.

This method will figure out the correct offsets to send to the consumer group coordinator.


consumer class

A client that consumes messages from kafka topics.

make-instance accepts the following keyword args:

Example:

(let ((consumer (make-instance
                 'kf:consumer
                 :conf '("bootstrap.servers" "127.0.0.1:9092"
                         "group.id" "consumer-group-id"
                         "enable.auto.commit" "false"
                         "auto.offset.reset" "earliest")
                 :serde #'babel:octets-to-string)))
  (kf:subscribe consumer "topic-name")

  (loop
     for message = (kf:poll consumer 2000)
     while message

     for key = (kf:key message)
     for value = (kf:value message)

     collect (list key value)

     do (kf:commit consumer)))

poll

((consumer consumer) (timeout-ms integer))

Block for up to timeout-ms milliseconds and return a message or nil.

May signal partition-error or condition from consumer's serde. A store-function restart will be provided if it's a serde condition.


seek

((consumer consumer) (topic string) (partition integer) (offset integer) (timeout-ms integer))

Block for up to timeout-ms milliseconds and seek consumer to offset.


seek-to-beginning

((consumer consumer) (topic string) (partition integer) (timeout-ms integer))

Block for up to timeout-ms milliseconds and seek consumer to beginning of partition.


seek-to-end

((consumer consumer) (topic string) (partition integer) (timeout-ms integer))

Block for up to timeout-ms milliseconds and seek consumer to end of partition.


subscribe

sequence specialization

((consumer consumer) (topics sequence))

Subscribe consumer to topics.

Any topic prefixed with ^ will be regex-matched with the cluster's topics.

string specialization

((consumer consumer) (topic string))

Subscribe consumer to topic.

If topic starts with ^, then it will be regex-matched with the cluster's topics.


unsubscribe

((consumer consumer))

Unsubscribe consumer from its current topic subscription.


subscription

((consumer consumer))

Return a list of topic names that consumer is subscribed to.


assign

((consumer consumer) (partitions sequence))

Assign partitions to consumer.

partitions should be a sequence of (topic . partition) cons cells.


assignment

((consumer consumer))

Return a (topic . partition) list of partitions assigned to consumer.


commit

((consumer consumer) &key offsets asyncp)

Commit offsets to broker.

If offsets is nil, then the current assignment is committed; otherwise, offsets should be an alist mapping (topic . partition) cons cells to either (offset . metadata) cons cells or lone offset values.

On success, an alist of committed offsets is returned, mapping (topic . partition) to (offset . metadata).

On failure, either an rdkafka-error or partial-error is signalled. The partial-error will have the slots:

If asyncp is true, then a future will be returned instead.


committed

((consumer consumer) (partitions sequence) (timeout-ms integer))

Block for up to timeout-ms milliseconds and return committed offsets for partitions.

partitions should be a sequence of (topic . partition) cons cells.

On success, an alist of committed offsets is returned, mapping (topic . partition) to (offset . metadata).

On failure, either an rdkafka-error or partial-error is signalled. The partial-error will have the slots:


pause

((consumer consumer) (partitions sequence))

Pause consumption from partitions.

partitions should be a sequence of (topic . partition) cons cells.

partitions is returned on success.

On failure, either an rdkafka-error or partial-error is signalled. The partial-error will have the slots:


resume

((consumer consumer) (partitions sequence))

Resume consumption from partitions.

partitions should be a sequence of (topic . partition) cons cells.

partitions is returned on success.

On failure, either an rdkafka-error or partial-error is signalled. The partial-error will have the slots:


member-id

((consumer consumer))

Return consumer's broker-assigned group member-id.


offsets-for-times

((consumer consumer) (timestamps list) (timeout-ms integer))

Look up the offsets for the given partitions by timestamp.

The returned offset for each partition is the earliest offset whose timestamp is greater than or equal to the given timestamp in timestamps.

timestamps should be an alist mapping (topic . partition) cons cells to timestamp values.

On success, an alist of offsets is returned, mapping (topic . partition) cons cells to offset values.

On failure, either an rdkafka-error or partial-error is signalled. The partial-error will have the slots:


watermarks

((consumer consumer) (topic string) (partition integer) (timeout-ms integer))

Query broker for low (oldest/beginning) and high (newest/end) offsets.

A (low . high) cons cell is returned.


positions

((consumer consumer) (partitions sequence))

Retrieve current positions (offsets) for partitions.

partitions should be a sequence of (topic . partition) cons cells.

On success, an alist of positions is returned, mapping (topic . partition) to one of either:

On failure, either an rdkafka-error or partial-error is signalled. The partial-error will have the slots:


close

((consumer consumer))

Close consumer after revoking assignment, committing offsets, and leaving group.

consumer will be closed during garbage collection if it's still open; this method is provided if closing needs to occur at a well-defined time.


message class

A kafka message as returned by consumer's poll or producer's send.

make-instance should not be called with this class.

Example:

(let ((message (kf:poll consumer 5000)))
  (kf:key message)
  ;; => "key-1", #(107 101 121 45 49)

  (kf:value message)
  ;; => "Hello", #(72 101 108 108 111)

  (kf:topic message)
  ;; => "foobar"

  (kf:partition message)
  ;; => 0

  (kf:offset message)
  ;; => 0

  (kf:timestamp message)
  ;; => 1577002478269, :CREATE-TIME

  (kf:headers message)
  ;; => '(("one" . #(1 2 3))
  ;;      ("two" . #(4 5 6)))

  )

key

((message message))

Return (values deserialized-key serialized-key) from message.


value

((message message))

Return (values deserialized-value serialized-value) from message.


topic

((message message))

Return the topic message originated from.


partition

((message message))

Return the partition message originated from.


offset

((message message))

Return the offset for message.


timestamp

((message message))

Return (values timestamp timestamp-type) from message.

If timestamp is not available, then nil is returned. Otherwise:


headers

((message message))

Return headers from message as an alist mapping strings to byte vectors.


future class

A future to hold the result of an async operation.

make-instance should not be called with this class.

Example:

(let ((future (kf:send producer "topic" "message")))
  (kf:donep future) ;; => nil
  (kf:value future) ;; => #<MESSAGE {1005BE9D23}>
  (kf:donep future) ;; => t

  (let ((new-future (kf:then future
                             (lambda (message err)
                               (when err
                                 (error err))
                               (kf:value message)))))
    (kf:value new-future))) ;; => "message"

value

((future future))

Wait until future is done and return its value or signal its condition.


then

((future future) (callback function))

Return a new future that calls callback when current future completes.

callback should be a binary function accepting the positional args:

  1. value: the value that the current future evaluates to, or nil when it signals a condition.
  2. condition: the condition signalled by the current future, or nil when it does not signal a condition.

callback is called in a background thread.


donep

((future future))

Determine if future is done processing.


conditions

The conditions are structured in the following class hierarchy:


kafka-error

Generic condition signalled by cl-rdkafka for expected errors.

Slot readers:


rdkafka-error

Condition signalled for librdkafka errors.

Slot readers:


partition-error

Condition signalled for errors specific to a topic's partition.

Slot readers:


transaction-error

Condition signalled for errors related to transactions.

Slot readers:


retryable-operation-error

Condition signalled by retryable operations that fail during transactions.

Slot readers:


abort-required-error

Condition signalled when a transaction fails and must be aborted.

Slot readers:


fatal-error

Condition signalled for librdkafka fatal errors.

These conditions indicate that the producer or consumer instance should no longer be used.


partial-error

Condition signalled for operations that partially failed.

Slot readers:


allocation-error

Condition signalled when librdkafka functions fail to allocate pointers.

Slot readers:


Admin API

The admin API is still baking :bread:, so it's not publicly exposed. The admin functionality is accessible if needed (see tests for usage examples), but it will be changing significantly in the near future.


2 Systems

The main system appears first, followed by any subsystem dependency.


Previous: , Up: Systems   [Contents][Index]

2.1 cl-rdkafka

A client library for Apache Kafka based on librdkafka CFFI bindings.

Author

Sahil Kang <sahil.kang@asilaycomputing.com>

License

GPLv3

Version

1.1.0

Defsystem Dependency

cffi-grovel (system).

Dependencies
  • cffi (system).
  • trivial-garbage (system).
  • bordeaux-threads (system).
  • lparallel (system).
Source

cl-rdkafka.asd.

Child Components

3 Modules

Modules are listed depth-first from the system components tree.


Next: , Previous: , Up: Modules   [Contents][Index]

3.1 cl-rdkafka/low-level

Source

cl-rdkafka.asd.

Parent Component

cl-rdkafka (system).

Child Components

3.2 cl-rdkafka/high-level

Dependency

low-level (module).

Source

cl-rdkafka.asd.

Parent Component

cl-rdkafka (system).

Child Components

3.3 cl-rdkafka/high-level/event-io

Dependencies
Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Child Components

3.4 cl-rdkafka/high-level/admin

Dependencies
Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Child Components

4 Files

Files are sorted by type and then listed depth-first from the systems components trees.


Previous: , Up: Files   [Contents][Index]

4.1 Lisp


4.1.1 cl-rdkafka/cl-rdkafka.asd

Source

cl-rdkafka.asd.

Parent Component

cl-rdkafka (system).

ASDF Systems

cl-rdkafka.


4.1.2 cl-rdkafka/low-level/package.lisp

Source

cl-rdkafka.asd.

Parent Component

low-level (module).

Packages

cl-rdkafka/low-level.


4.1.3 cl-rdkafka/low-level/librdkafka-grovel.lisp

Dependency

package.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

low-level (module).


4.1.4 cl-rdkafka/low-level/librdkafka-bindings.lisp

Dependency

librdkafka-grovel.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

low-level (module).

Public Interface
Internals

4.1.5 cl-rdkafka/high-level/package.lisp

Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Packages

cl-rdkafka.


4.1.6 cl-rdkafka/high-level/common.lisp

Dependency

package.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Internals

4.1.7 cl-rdkafka/high-level/conditions.lisp

Dependency

package.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Public Interface
Internals

4.1.8 cl-rdkafka/high-level/conf.lisp

Dependency

common.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Internals

4.1.9 cl-rdkafka/high-level/serde.lisp

Dependency

common.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Internals

4.1.10 cl-rdkafka/high-level/message.lisp

Dependencies
Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Public Interface
Internals

4.1.11 cl-rdkafka/high-level/event-io/posix-grovel.lisp

Source

cl-rdkafka.asd.

Parent Component

event-io (module).


4.1.12 cl-rdkafka/high-level/event-io/posix.lisp

Dependency

posix-grovel.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

event-io (module).

Internals

4.1.13 cl-rdkafka/high-level/event-io/kernel.lisp

Dependency

posix.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

event-io (module).

Internals

4.1.14 cl-rdkafka/high-level/future.lisp

Dependency

event-io (module).

Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Public Interface

4.1.15 cl-rdkafka/high-level/toppar.lisp

Dependencies
Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Internals

4.1.16 cl-rdkafka/high-level/consumer.lisp

Dependencies
Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Public Interface
Internals

4.1.17 cl-rdkafka/high-level/producer.lisp

Dependency

consumer.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Public Interface
Internals

4.1.18 cl-rdkafka/high-level/admin/common.lisp

Source

cl-rdkafka.asd.

Parent Component

admin (module).

Internals

4.1.19 cl-rdkafka/high-level/admin/create-topic.lisp

Dependency

common.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

admin (module).

Internals

4.1.20 cl-rdkafka/high-level/admin/delete-topic.lisp

Dependency

common.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

admin (module).

Internals

4.1.21 cl-rdkafka/high-level/admin/create-partitions.lisp

Dependency

common.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

admin (module).

Internals

4.1.22 cl-rdkafka/high-level/admin/config.lisp

Dependency

common.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

admin (module).

Internals

4.1.23 cl-rdkafka/high-level/admin/cluster-metadata.lisp

Dependency

common.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

admin (module).

Internals

4.1.24 cl-rdkafka/high-level/admin/group-info.lisp

Dependency

common.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

admin (module).

Internals

5 Packages

Packages are listed by definition order.


Next: , Previous: , Up: Packages   [Contents][Index]

5.1 cl-rdkafka/low-level

Source

package.lisp.

Nickname

cl-rdkafka/ll

Use List

common-lisp.

Public Interface
Internals

5.2 cl-rdkafka

Source

package.lisp.

Nickname

kf

Use List

common-lisp.

Public Interface
Internals

6 Definitions

Definitions are sorted by export status, category, package, and then by lexicographic order.


Next: , Previous: , Up: Definitions   [Contents][Index]

6.1 Public Interface


Next: , Previous: , Up: Public Interface   [Contents][Index]

6.1.1 Constants

Constant: rd-kafka-admin-op--cnt
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-admin-op-alterconfigs
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-admin-op-any
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-admin-op-createpartitions
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-admin-op-createtopics
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-admin-op-deletetopics
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-admin-op-describeconfigs
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-conf-invalid
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-conf-ok
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-conf-unknown
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-config-source--cnt
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-config-source-default-config
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-config-source-dynamic-broker-config
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-config-source-dynamic-default-broker-config
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-config-source-dynamic-topic-config
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-config-source-static-broker-config
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-config-source-unknown-config
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-consumer
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-msg-status-not-persisted
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-msg-status-persisted
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-msg-status-possibly-persisted
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-producer
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resource--cnt
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resource-any
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resource-broker
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resource-group
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resource-topic
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resource-unknown
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--all-brokers-down
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--application
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--assign-partitions
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--assignment-lost
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--authentication
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--bad-compression
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--bad-msg
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--begin
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--conflict
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--crit-sys-resource
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--destroy
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--end
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--existing-subscription
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--fail
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--fatal
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--fenced
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--fs
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--gapless-guarantee
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--in-progress
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--inconsistent
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--intr
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--invalid-arg
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--invalid-type
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--isr-insuff
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--key-deserialization
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--key-serialization
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--max-poll-exceeded
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--msg-timed-out
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--no-offset
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--node-update
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--noent
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--noop
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--not-configured
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--not-implemented
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--outdated
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--partial
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--partition-eof
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--prev-in-progress
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--purge-inflight
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--purge-queue
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--queue-full
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--read-only
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--resolve
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--retry
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--revoke-partitions
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--ssl
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--state
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--timed-out
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--timed-out-queue
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--transport
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--underflow
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--unknown-broker
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--unknown-group
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--unknown-partition
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--unknown-protocol
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--unknown-topic
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--unsupported-feature
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--value-deserialization
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--value-serialization
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--wait-cache
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err--wait-coord
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-broker-not-available
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-cluster-authorization-failed
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-concurrent-transactions
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-coordinator-load-in-progress
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-coordinator-not-available
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-delegation-token-auth-disabled
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-delegation-token-authorization-failed
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-delegation-token-expired
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-delegation-token-not-found
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-delegation-token-owner-mismatch
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-delegation-token-request-not-allowed
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-duplicate-resource
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-duplicate-sequence-number
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-election-not-needed
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-eligible-leaders-not-available
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-feature-update-failed
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-fenced-instance-id
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-fenced-leader-epoch
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-fetch-session-id-not-found
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-group-authorization-failed
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-group-id-not-found
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-group-max-size-reached
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-group-subscribed-to-topic
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-illegal-generation
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-illegal-sasl-state
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-inconsistent-group-protocol
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-inconsistent-voter-set
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-commit-offset-size
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-config
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-fetch-session-epoch
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-group-id
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-msg
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-msg-size
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-partitions
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-principal-type
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-producer-epoch
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-producer-id-mapping
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-record
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-replica-assignment
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-replication-factor
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-request
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-required-acks
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-session-timeout
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-timestamp
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-transaction-timeout
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-txn-state
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-invalid-update-version
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-kafka-storage-error
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-leader-not-available
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-listener-not-found
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-log-dir-not-found
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-member-id-required
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-msg-size-too-large
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-network-exception
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-no-error
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-no-reassignment-in-progress
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-non-empty-group
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-not-controller
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-not-coordinator
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-not-enough-replicas
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-not-enough-replicas-after-append
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-not-leader-for-partition
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-offset-metadata-too-large
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-offset-not-available
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-offset-out-of-range
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-operation-not-attempted
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-out-of-order-sequence-number
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-policy-violation
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-preferred-leader-not-available
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-principal-deserialization-failure
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-producer-fenced
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-reassignment-in-progress
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-rebalance-in-progress
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-record-list-too-large
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-replica-not-available
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-request-timed-out
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-resource-not-found
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-sasl-authentication-failed
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-security-disabled
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-stale-broker-epoch
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-stale-ctrl-epoch
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-throttling-quota-exceeded
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-topic-already-exists
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-topic-authorization-failed
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-topic-deletion-disabled
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-topic-exception
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-transaction-coordinator-fenced
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-transactional-id-authorization-failed
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-unacceptable-credential
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-unknown
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-unknown-leader-epoch
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-unknown-member-id
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-unknown-producer-id
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-unknown-topic-or-part
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-unstable-offset-commit
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-unsupported-compression-type
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-unsupported-for-message-format
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-unsupported-sasl-mechanism
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-resp-err-unsupported-version
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-timestamp-create-time
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-timestamp-log-append-time
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-timestamp-not-available
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-vtype-end
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-vtype-header
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-vtype-headers
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-vtype-key
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-vtype-msgflags
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-vtype-opaque
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-vtype-partition
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-vtype-rkt
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-vtype-timestamp
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-vtype-topic
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Constant: rd-kafka-vtype-value
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.


6.1.2 Macros

Macro: rd-kafka-error-new (code fmt &rest varargs0)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Macro: rd-kafka-producev (rk &rest varargs0)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.


6.1.3 Ordinary functions

Function: rd-kafka-abort-transaction (rk timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-adminoptions-destroy (options)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-adminoptions-new (rk for-api)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-adminoptions-set-broker (options broker-id errstr errstr-size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-adminoptions-set-opaque (options opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-adminoptions-set-operation-timeout (options timeout-ms errstr errstr-size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-adminoptions-set-request-timeout (options timeout-ms errstr errstr-size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-adminoptions-set-validate-only (options true-or-false errstr errstr-size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-alterconfigs (rk configs config-cnt options rkqu)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-alterconfigs-result-resources (result cntp)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-assign (rk partitions)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-assignment (rk partitions)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-begin-transaction (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-brokers-add (rk brokerlist)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-clusterid (rk timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-commit (rk offsets async)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-commit-message (rk rkmessage async)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-commit-queue (rk offsets rkqu cb opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-commit-transaction (rk timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-committed (rk partitions timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-destroy (conf)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-dump (conf cntp)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-dump-free (arr cnt)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-dup (conf)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-dup-filter (conf filter-cnt filter)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-get (conf name dest dest-size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-interceptor-add-on-conf-destroy (conf ic-name on-conf-destroy ic-opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-interceptor-add-on-conf-dup (conf ic-name on-conf-dup ic-opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-interceptor-add-on-conf-set (conf ic-name on-conf-set ic-opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-interceptor-add-on-new (conf ic-name on-new ic-opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-new ()
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-properties-show (fp)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set (conf name value errstr errstr-size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set-background-event-cb (conf event-cb)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set-closesocket-cb (conf closesocker-cb)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set-connect-cb (conf connect-cb)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set-consume-cb (conf consume-db)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set-default-topic-conf (conf tconf)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set-dr-cb (conf dr-cb)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set-dr-msg-cb (conf dr-msg-cb)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set-error-cb (conf error-cb)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set-events (conf events)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set-log-cb (conf log-cb)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set-offset-commit-cb (conf offset-commit-cb)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set-opaque (conf opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set-open-cb (conf open-cb)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set-rebalance-cb (conf rebalance-cb)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set-socket-cb (conf socket-cb)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set-stats-cb (conf stats-cb)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-conf-set-throttle-cb (conf throttle-cb)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configentry-is-default (entry)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configentry-is-read-only (entry)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configentry-is-sensitive (entry)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configentry-is-synonym (entry)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configentry-name (entry)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configentry-source (entry)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configentry-synonyms (entry cntp)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configentry-value (entry)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configresource-configs (config cntp)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configresource-destroy (config)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configresource-destroy-array (config config-cnt)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configresource-error (config)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configresource-error-string (config)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configresource-name (config)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configresource-new (restype resname)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configresource-set-config (config name value)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configresource-type (config)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-configsource-name (conf-source)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-consume (rkt partition timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-consume-batch (rkt partition timeout-ms rkmessages rkmessages-size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-consume-batch-queue (rkqu timeout-ms rkmessages rkmessages-size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-consume-callback (rkt partition timeout-ms consume-cb opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-consume-callback-queue (rkqu timeout-ms consume-cb opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-consume-queue (rkqu timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-consume-start (rkt partition offset)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-consume-start-queue (rkt partition offset rkqu)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-consume-stop (rkt partition)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-consumer-close (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-consumer-group-metadata (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-consumer-group-metadata-destroy (cgmd)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-consumer-group-metadata-new (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-consumer-group-metadata-read (cgmd buffer size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-consumer-group-metadata-write (cgmd bufferp sizep)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-consumer-poll (rk timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-controllerid (rk timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-createpartitions (rk new-parts new-parts-cnt options rkqu)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-createpartitions-result-topics (result cntp)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-createtopics (rk new-topics new-topic-cnt options rkqu)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-createtopics-result-topics (result cntp)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-default-topic-conf-dup (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-deletetopic-destroy (del-topic)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-deletetopic-destroy-array (del-topics del-topic-cnt)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-deletetopic-new (topic)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-deletetopics (rk del-topics del-topic-cnt options rkqu)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-deletetopics-result-topics (result cntp)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-describeconfigs (rk configs config-cnt options rkqu)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-describeconfigs-result-resources (result cntp)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-destroy (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-destroy-flags (rk flags)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-dump (rp rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-err2name (err)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-err2str (err)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-errno ()
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-errno2err (errnox)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-error-code (error)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-error-destroy (error)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-error-is-fatal (error)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-error-is-retriable (error)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-error-name (error)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-error-string (error)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-error-txn-requires-abort (error)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-alterconfigs-result (rkev)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-createpartitions-result (rkev)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-createtopics-result (rkev)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-debug-contexts (rkev dst dstsize)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-deletetopics-result (rkev)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-describeconfigs-result (rkev)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-destroy (rkev)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-error (rkev)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-error-is-fatal (rkev)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-error-string (rkev)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-log (rkev fac str level)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-message-array (rkev rkmessages size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-message-count (rkev)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-message-next (rkev)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-name (rkev)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-opaque (rkev)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-stats (rkev)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-topic-partition (rkev)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-topic-partition-list (rkev)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-event-type (rkev)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-fatal-error (rk errstr errstr-size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-flush (rk timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-get-debug-contexts ()
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-get-err-descs (rd-kafka-err-desc cntp)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-get-watermark-offsets (rk topic partition low high)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-group-list-destroy (grplist)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-header-add (hdrs name name-size value value-size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-header-cnt (hdrs)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-header-get (hdrs idx name valuep sizep)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-header-get-all (hdrs idx namep valuep sizep)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-header-get-last (hdrs name valuep sizep)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-header-remove (hdrs name)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-headers-copy (src)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-headers-destroy (hdrs)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-headers-new (initial-count)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-init-transactions (rk timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-interceptor-add-on-acknowledgement (rk ic-name on-acknowledgement ic-opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-interceptor-add-on-commit (rk ic-name on-commit ic-opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-interceptor-add-on-consume (rk ic-name on-consume ic-opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-interceptor-add-on-destroy (rk ic-name on-destroy ic-opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-interceptor-add-on-request-sent (rk ic-name on-request-sent ic-opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-interceptor-add-on-send (rk ic-name on-send ic-opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-last-error ()
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-list-groups (rk group grplistp timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-log-print (rk level fac buf)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-log-syslog (rk level fac buf)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-mem-free (rk ptr)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-memberid (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-message-destroy (rkmessage)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-message-detach-headers (rkmessage hdrsp)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-message-headers (rkmessage hdrsp)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-message-latency (rkmessage)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-message-set-headers (rkmessage hdrs)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-message-status (rkmessage)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-message-timestamp (rkmessage tstype)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-metadata (rk all-topics only-rkt metadatap timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-metadata-destroy (metadata)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-msg-partitioner-consistent (rkt key keylen partition-cnt opaque msg-options)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-msg-partitioner-consistent-random (rkt key keylen partition-cnt opaque msg-opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-msg-partitioner-murmur2 (rkt key keylen partition-cnt rkt-opaque msg-opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-msg-partitioner-murmur2-random (rkt key keylen partition-cnt rkt-opaque msg-options)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-msg-partitioner-random (rkt key keylen partition-cnt opaque msg-options)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-name (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-new (type conf errstr errstr-size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-newpartitions-destroy (new-parts)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-newpartitions-destroy-array (new-parts new-parts-cnt)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-newpartitions-new (topic new-total-cnt errstr errstr-size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-newpartitions-set-replica-assignment (new-parts new-partition-idx broker-ids broker-id-cnt errstr errstr-size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-newtopic-destroy (new-topic)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-newtopic-destroy-array (new-topics new-topic-cnt)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-newtopic-new (topic num-partitions replication-factor errstr errstr-size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-newtopic-set-config (new-topic name value)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-newtopic-set-replica-assignment (new-topic partition broker-ids broker-id-cnt errstr errstr-size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-offset-store (rkt partition offset)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-offsets-for-times (rk offsets timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-offsets-store (rk offsets)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-opaque (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-outq-len (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-pause-partitions (rk partitions)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-poll (rk timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-poll-set-consumer (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-position (rk partitions)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-produce (rkt partition msgflags payload len key keylen msg-opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-produce-batch (rkt partition msgflags rkmessages message-cnt)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-purge (rk purge-flags)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-query-watermark-offsets (rk topic partitoin low high timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-queue-cb-event-enable (rkqu event-cb opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-queue-destroy (rkqu)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-queue-forward (src dst)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-queue-get-background (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-queue-get-consumer (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-queue-get-main (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-queue-get-partition (rk topic partition)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-queue-io-event-enable (rkqu fd payload size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-queue-length (rkqu)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-queue-new (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-queue-poll (rkqu timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-queue-poll-callback (rkqu timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-resourcetype-name (resttype)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-resume-partitions (rk partitions)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-seek (rkt partition offset timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-send-offsets-to-transaction (rk offsets cgmetadata timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-set-log-level (rk level)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-set-log-queue (rk rkqu)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-set-logger (rk func)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-subscribe (rk topics)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-subscription (rk topics)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-test-fatal-error (rk err reason)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-thread-cnt ()
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-conf-destroy (topic-conf)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-conf-dump (conf cntp)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-conf-dup (conf)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-conf-get (conf name dest dest-size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-conf-new ()
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-conf-set (conf name value errstr errstr-size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-conf-set-msg-order-cmp (topic-conf msg-order-cmp)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-conf-set-opaque (conf opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-conf-set-partitioner-cb (topic-conf partitioner)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-destroy (rkt)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-name (rkt)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-new (rk topic conf)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-opaque (rtk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-partition-available (rkt partition)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-partition-destroy (rktpar)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-partition-list-add (rktparlist topic partition)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-partition-list-add-range (rktparlist topic start stop)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-partition-list-copy (src)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-partition-list-del (rktparlist topic partition)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-partition-list-del-by-idx (rktparlist idx)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-partition-list-destroy (rkparlist)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-partition-list-find (rktparlist topic partition)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-partition-list-new (size)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-partition-list-set-offset (rktparlist topic partition offset)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-partition-list-sort (rktparlist cmp opaque)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-result-error (topicres)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-result-error-string (topicres)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-topic-result-name (topicres)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-type (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-unittest ()
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-unsubscribe (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-version ()
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-version-str ()
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-wait-destroyed (timeout-ms)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: rd-kafka-yield (rk)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.


6.1.4 Generic functions

Generic Function: abort-transaction (producer timeout-ms)
Package

cl-rdkafka.

Source

producer.lisp.

Methods
Method: abort-transaction ((producer producer) (timeout-ms integer))

Block for up to TIMEOUT-MS milliseconds and abort the ongoing transaction.

A transaction must have been started by BEGIN-TRANSACTION.

This method will purge all enqueued messages before issuing the
abort.

May signal a FATAL-ERROR, TRANSACTION-ERROR, or RETRYABLE-OPERATION-ERROR. A RETRY-OPERATION and CONTINUE restart will be provided if it’s a RETRYABLE-OPERATION-ERROR.

Generic Function: assign (consumer partitions)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: assign ((consumer consumer) (partitions sequence))

Assign PARTITIONS to CONSUMER.

PARTITIONS should be a sequence of (topic . partition) cons cells.

Generic Function: assignment (consumer)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: assignment ((consumer consumer))

Return a (topic . partition) list of partitions assigned to CONSUMER.

Generic Reader: baddies (condition)
Package

cl-rdkafka.

Methods
Reader Method: baddies ((condition partial-error))
Source

conditions.lisp.

Target Slot

baddies.

Generic Function: begin-transaction (producer)
Package

cl-rdkafka.

Source

producer.lisp.

Methods
Method: begin-transaction ((producer producer))

Begin a transaction.

INITIALIZE-TRANSACTIONS must have been called exactly once before this method, and only one transaction can be in progress at a time for PRODUCER.

The transaction can be committed with COMMIT-TRANSACTION or aborted with ABORT-TRANSACTION.

May signal FATAL-ERROR or TRANSACTION-ERROR.

Generic Function: close (consumer)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: close ((consumer consumer))

Close CONSUMER after revoking assignment, committing offsets, and leaving group.

CONSUMER will be closed during garbage collection if it’s still open;
this method is provided if closing needs to occur at a well-defined
time.

Generic Function: commit (consumer &key offsets asyncp)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: commit ((consumer consumer) &key offsets asyncp)

Commit OFFSETS to broker.

If OFFSETS is nil, then the current assignment is committed; otherwise, OFFSETS should be an alist mapping (topic . partition) cons cells to either (offset . metadata) cons cells or lone offset values.

On success, an alist of committed offsets is returned, mapping (topic . partition) to (offset . metadata).

On failure, either an RDKAFKA-ERROR or PARTIAL-ERROR is signalled. The PARTIAL-ERROR will have the slots:
* GOODIES: Same format as successful return value
* BADDIES: An alist mapping (topic . partition) to RDKAFKA-ERROR

If ASYNCP is true, then a FUTURE will be returned instead.

Generic Function: commit-transaction (producer timeout-ms)
Package

cl-rdkafka.

Source

producer.lisp.

Methods
Method: commit-transaction ((producer producer) (timeout-ms integer))

Block for up to TIMEOUT-MS milliseconds and commit the ongoing transaction.

A transaction must have been started by BEGIN-TRANSACTION.

This method will flush all enqueued messages before issuing the
commit. If any of the messages fails to be sent, an ABORT-REQUIRED-ERROR will be signalled.

May signal:

* RETRYABLE-OPERATION-ERROR, in which case a RETRY-OPERATION and ABORT restart will be provided.

* ABORT-REQUIRED-ERROR, in which case an ABORT restart will be provided.

* TRANSACTION-ERROR

* FATAL-ERROR

Generic Function: committed (consumer partitions timeout-ms)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: committed ((consumer consumer) (partitions sequence) (timeout-ms integer))

Block for up to TIMEOUT-MS milliseconds and return committed offsets for PARTITIONS.

PARTITIONS should be a sequence of (topic . partition) cons cells.

On success, an alist of committed offsets is returned, mapping
(topic . partition) to (offset . metadata).

On failure, either an RDKAFKA-ERROR or PARTIAL-ERROR is signalled.
The PARTIAL-ERROR will have the slots:
* GOODIES: Same format as successful return value
* BADDIES: An alist mapping (topic . partition) to RDKAFKA-ERROR

Generic Reader: description (condition)
Package

cl-rdkafka.

Methods
Reader Method: description ((condition allocation-error))
Source

conditions.lisp.

Target Slot

description.

Reader Method: description ((condition kafka-error))
Source

conditions.lisp.

Target Slot

description.

Generic Function: donep (future)
Package

cl-rdkafka.

Source

future.lisp.

Methods
Method: donep ((future future))

Determine if FUTURE is done processing.

Generic Reader: enum (condition)
Package

cl-rdkafka.

Methods
Reader Method: enum ((condition rdkafka-error))
Source

conditions.lisp.

Target Slot

enum.

Generic Function: flush (producer)
Package

cl-rdkafka.

Source

producer.lisp.

Methods
Method: flush ((producer producer))

Block while in-flight messages are sent to kafka cluster.

Generic Reader: goodies (condition)
Package

cl-rdkafka.

Methods
Reader Method: goodies ((condition partial-error))
Source

conditions.lisp.

Target Slot

goodies.

Generic Reader: headers (object)
Package

cl-rdkafka.

Methods
Reader Method: headers ((message message))

Message headers as an alist, or nil.

Source

message.lisp.

Target Slot

headers.

Generic Function: initialize-transactions (producer timeout-ms)
Package

cl-rdkafka.

Source

producer.lisp.

Methods
Method: initialize-transactions ((producer producer) (timeout-ms integer))

Block for up to TIMEOUT-MS milliseconds and initialize transactions for PRODUCER.

When transactional.id is configured, this method needs to be called
exactly once before any other methods on PRODUCER.

This method:

1) Ensures any transactions initiated by previous producer instances
with the same transactional.id are completed:

* If the previous instance had failed with an in-progress
transaction, it will be aborted.

* If the previous transaction had started committing, but had
not yet finished, this method waits for it to finish.

2) Acquires the internal producer id and epoch to use with all
future transactional messages sent by PRODUCER. This will be used
to fence out any previous instances.

May signal a FATAL-ERROR, TRANSACTION-ERROR, or
RETRYABLE-OPERATION-ERROR. A RETRY-OPERATION restart will be provided
if it’s a RETRYABLE-OPERATION-ERROR.

Generic Function: key (message)
Package

cl-rdkafka.

Source

message.lisp.

Methods
Method: key ((message message))

Return (values deserialized-key serialized-key) from MESSAGE.

Generic Function: member-id (consumer)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: member-id ((consumer consumer))

Return CONSUMER’s broker-assigned group member-id.

Generic Reader: name (condition)
Package

cl-rdkafka.

Methods
Reader Method: name ((condition allocation-error))
Source

conditions.lisp.

Target Slot

name.

Generic Reader: offset (object)
Package

cl-rdkafka.

Methods
Reader Method: offset ((message message))

Message offset.

Source

message.lisp.

Target Slot

offset.

Generic Function: offsets-for-times (consumer timestamps timeout-ms)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: offsets-for-times ((consumer consumer) (timestamps list) (timeout-ms integer))

Look up the offsets for the given partitions by timestamp.

The returned offset for each partition is the earliest offset whose timestamp is greater than or equal to the given timestamp in TIMESTAMPS.

TIMESTAMPS should be an alist mapping (topic . partition) cons cells to timestamp values.

On success, an alist of offsets is returned, mapping
(topic . partition) cons cells to offset values.

On failure, either an RDKAFKA-ERROR or PARTIAL-ERROR is signalled. The PARTIAL-ERROR will have the slots:
* GOODIES: Same format as successful return value
* BADDIES: An alist mapping (topic . partition) to RDKAFKA-ERROR

Generic Reader: partition (condition)
Package

cl-rdkafka.

Methods
Reader Method: partition ((message message))

The partition this message originated from.

Source

message.lisp.

Target Slot

partition.

Reader Method: partition ((condition partition-error))
Source

conditions.lisp.

Target Slot

partition.

Generic Function: pause (consumer partitions)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: pause ((consumer consumer) (partitions sequence))

Pause consumption from PARTITIONS.

PARTITIONS should be a sequence of (topic . partition) cons cells.

PARTITIONS is returned on success.

On failure, either an RDKAFKA-ERROR or PARTIAL-ERROR is signalled. The PARTIAL-ERROR will have the slots:
* GOODIES: A list of (topic . partition) cons cells
* BADDIES: An alist mapping (topic . partition) to RDKAFKA-ERROR

Generic Function: poll (consumer timeout-ms)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: poll ((consumer consumer) (timeout-ms integer))

Block for up to TIMEOUT-MS milliseconds and return a MESSAGE or nil.

May signal PARTITION-ERROR or condition from CONSUMER’s serde. A STORE-FUNCTION restart will be provided if it’s a serde condition.

Generic Function: positions (consumer partitions)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: positions ((consumer consumer) (partitions sequence))

Retrieve current positions (offsets) for PARTITIONS.

PARTITIONS should be a sequence of (topic . partition) cons cells.

On success, an alist of positions is returned, mapping
(topic . partition) to one of either:
* 1 plus the last consumed message offset
* nil if there was no previous message.

On failure, either an RDKAFKA-ERROR or PARTIAL-ERROR is signalled. The PARTIAL-ERROR will have the slots:
* GOODIES: Same format as successful return value
* BADDIES: An alist mapping (topic . partition) to RDKAFKA-ERROR

Generic Function: resume (consumer partitions)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: resume ((consumer consumer) (partitions sequence))

Resume consumption from PARTITIONS.

PARTITIONS should be a sequence of (topic . partition) cons cells.

PARTITIONS is returned on success.

On failure, either an RDKAFKA-ERROR or PARTIAL-ERROR is signalled. The PARTIAL-ERROR will have the slots:
* GOODIES: A list of (topic . partition) cons cells
* BADDIES: An alist mapping (topic . partition) to RDKAFKA-ERROR

Generic Function: seek (consumer topic partition offset timeout-ms)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: seek ((consumer consumer) (topic string) (partition integer) (offset integer) (timeout-ms integer))

Block for up to TIMEOUT-MS milliseconds and seek CONSUMER to OFFSET.

Generic Function: seek-to-beginning (consumer topic partition timeout-ms)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: seek-to-beginning ((consumer consumer) (topic string) (partition integer) (timeout-ms integer))

Block for up to TIMEOUT-MS milliseconds and seek CONSUMER to beginning of PARTITION.

Generic Function: seek-to-end (consumer topic partition timeout-ms)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: seek-to-end ((consumer consumer) (topic string) (partition integer) (timeout-ms integer))

Block for up to TIMEOUT-MS milliseconds and seek CONSUMER to end of PARTITION.

Generic Function: send (producer topic value &key key partition headers timestamp)
Package

cl-rdkafka.

Source

producer.lisp.

Methods
Method: send ((producer producer) (topic string) value &key key partition headers timestamp)

Asynchronously send a message and return a MESSAGE FUTURE.

If PARTITION is not specified, one is chosen using the TOPIC’s partitioner function.

If specified, HEADERS should be an alist mapping strings to byte-vectors.

TIMESTAMP is the number of milliseconds since the UTC epoch. If not specified, one will be generated by this call.

May signal PARTITION-ERROR or condition from PRODUCER’s serde. A STORE-FUNCTION restart will be provided if it’s a serde condition.

Generic Function: send-offsets-to-transaction (producer consumer offsets timeout-ms)

Send OFFSETS to CONSUMER group coordinator and mark them as part of the ongoing transaction.

A transaction must have been started by BEGIN-TRANSACTION.

This method will block for up to TIMEOUT-MS milliseconds.

OFFSETS should be associated with CONSUMER, and will be considered
committed only if the ongoing transaction is committed
successfully. Each offset should refer to the next message that the
CONSUMER POLL method should return: the last processed message’s
offset + 1. Invalid offsets will be ignored.

CONSUMER should have enable.auto.commit set to false and should not
commit offsets itself through the COMMIT method.

This method should be called at the end of a
consume->transform->produce cycle, before calling COMMIT-TRANSACTION.

May signal:

* RETRYABLE-OPERATION-ERROR, in which case a RETRY-OPERATION and
ABORT restart will be provided.

* ABORT-REQUIRED-ERROR, in which case an ABORT restart will be
provided.

* TRANSACTION-ERROR

* FATAL-ERROR

Package

cl-rdkafka.

Source

producer.lisp.

Methods
Method: send-offsets-to-transaction ((producer producer) (consumer consumer) (offsets sequence) (timeout-ms integer))

OFFSETS should be a sequence of MESSAGES processed by CONSUMER.

This method will figure out the correct offsets to send to the consumer group coordinator.

Method: send-offsets-to-transaction ((producer producer) (consumer consumer) (offsets hash-table) (timeout-ms integer))

OFFSETS should be a hash-table mapping (topic . partition) cons cells to either (offset . metadata) cons cells or lone offset values.

Method: send-offsets-to-transaction ((producer producer) (consumer consumer) (offsets list) (timeout-ms integer))

OFFSETS should be an alist mapping (topic . partition) cons cells to either (offset . metadata) cons cells or lone offset values.

Generic Function: subscribe (consumer topics)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: subscribe ((consumer consumer) (topic string))

Subscribe CONSUMER to TOPIC.

If TOPIC starts with ’^’, then it will be regex-matched with the cluster’s topics.

Method: subscribe ((consumer consumer) (topics sequence))

Subscribe CONSUMER to TOPICS.

Any topic prefixed with ’^’ will be regex-matched with the cluster’s topics.

Generic Function: subscription (consumer)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: subscription ((consumer consumer))

Return a list of topic names that CONSUMER is subscribed to.

Generic Function: then (future callback)
Package

cl-rdkafka.

Source

future.lisp.

Methods
Method: then ((future future) (callback function))

Return a new FUTURE that calls CALLBACK when current future completes.

CALLBACK should be a binary function accepting the positional args: 1) value: the value that the current future evaluates to, or nil when it signals a condition.
2) condition: the condition signalled by the current future, or nil when it does not signal a condition.

CALLBACK is called in a background thread.

Generic Function: timestamp (message)
Package

cl-rdkafka.

Source

message.lisp.

Methods
Method: timestamp ((message message))

Return (values timestamp timestamp-type) from MESSAGE.

If timestamp is not available, then nil is returned. Otherwise: * timestamp is the number of milliseconds since the UTC epoch * timestamp-type is either :create-time or :log-append-time

Generic Reader: topic (condition)
Package

cl-rdkafka.

Methods
Reader Method: topic ((message message))

The topic this message originated from.

Source

message.lisp.

Target Slot

topic.

Reader Method: topic ((condition partition-error))
Source

conditions.lisp.

Target Slot

topic.

Generic Function: unsubscribe (consumer)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: unsubscribe ((consumer consumer))

Unsubscribe CONSUMER from its current topic subscription.

Generic Function: value (message)
Package

cl-rdkafka.

Source

message.lisp.

Methods
Method: value ((future future))

Wait until FUTURE is done and return its value or signal its condition.

Source

future.lisp.

Method: value ((message message))

Return (values deserialized-value serialized-value) from MESSAGE.

Generic Function: watermarks (consumer topic partition timeout-ms)
Package

cl-rdkafka.

Source

consumer.lisp.

Methods
Method: watermarks ((consumer consumer) (topic string) (partition integer) (timeout-ms integer))

Query broker for low (oldest/beginning) and high (newest/end) offsets.

A (low . high) cons cell is returned.


6.1.5 Standalone methods

Method: initialize-instance :after ((consumer consumer) &key conf serde key-serde value-serde)
Source

consumer.lisp.

Method: initialize-instance :after ((producer producer) &key conf serde key-serde value-serde)
Source

producer.lisp.


6.1.6 Conditions

Condition: abort-required-error

Condition signalled when a transaction fails and must be aborted.

Package

cl-rdkafka.

Source

conditions.lisp.

Direct superclasses

transaction-error.

Condition: allocation-error

Condition signalled when librdkafka functions fail to allocate pointers.

Package

cl-rdkafka.

Source

conditions.lisp.

Direct superclasses

storage-condition.

Direct methods
Direct slots
Slot: name

Name of the object that failed to be allocated.

Initform

(quote (error "must supply name"))

Initargs

:name

Readers

name.

Writers

This slot is read-only.

Slot: description

Details about why the allocation may have failed.

Initform

(quote nil)

Initargs

:description

Readers

description.

Writers

This slot is read-only.

Condition: fatal-error

Condition signalled for librdkafka fatal errors.

These conditions indicate that the PRODUCER or CONSUMER instance should no longer be used.

Package

cl-rdkafka.

Source

conditions.lisp.

Direct superclasses

rdkafka-error.

Condition: kafka-error

Generic condition signalled by cl-rdkafka for expected errors.

Package

cl-rdkafka.

Source

conditions.lisp.

Direct superclasses

error.

Direct subclasses
Direct methods

description.

Direct slots
Slot: description

Hopefully some descriptive description describing the error.

Initform

(quote (error "must supply description"))

Initargs

:description

Readers

description.

Writers

This slot is read-only.

Condition: partial-error

Condition signalled for operations that partially failed.

Package

cl-rdkafka.

Source

conditions.lisp.

Direct superclasses

kafka-error.

Direct methods
Direct slots
Slot: goodies

Successful results.

Initform

(quote (error "must supply goodies"))

Initargs

:goodies

Readers

goodies.

Writers

This slot is read-only.

Slot: baddies

Unsuccessful results.

Initform

(quote (error "must supply baddies"))

Initargs

:baddies

Readers

baddies.

Writers

This slot is read-only.

Condition: partition-error

Condition signalled for errors specific to a topic’s partition.

Package

cl-rdkafka.

Source

conditions.lisp.

Direct superclasses

rdkafka-error.

Direct methods
Direct slots
Slot: topic

Topic name.

Initform

(quote (error "must supply topic"))

Initargs

:topic

Readers

topic.

Writers

This slot is read-only.

Slot: partition

Topic partition.

Initform

(quote (error "must supply partition"))

Initargs

:partition

Readers

partition.

Writers

This slot is read-only.

Condition: rdkafka-error

Condition signalled for librdkafka errors.

Package

cl-rdkafka.

Source

conditions.lisp.

Direct superclasses

kafka-error.

Direct subclasses
Direct methods

enum.

Direct slots
Slot: enum

cl-rdkafka/low-level:rd-kafka-resp-err enum symbol.

Initform

(quote (error "must supply enum"))

Initargs

:enum

Readers

enum.

Writers

This slot is read-only.

Condition: retryable-operation-error

Condition signalled by retryable operations that fail during transactions.

Package

cl-rdkafka.

Source

conditions.lisp.

Direct superclasses

transaction-error.

Condition: transaction-error

Condition signalled for errors related to transactions.

Package

cl-rdkafka.

Source

conditions.lisp.

Direct superclasses

rdkafka-error.

Direct subclasses

Previous: , Up: Public Interface   [Contents][Index]

6.1.7 Classes

Class: consumer

A client that consumes messages from kafka topics.

MAKE-INSTANCE accepts the following keyword args:

* CONF: A required plist, alist, or hash-table mapping config keys to their respective values; both keys and values should be strings. The provided key-value pairs are passed as-is to librdkafka, so consult the librdkafka config docs for more info.

* SERDE: An optional unary function accepting a byte vector and returning a deserialized value; defaults to #’identity.

* KEY-SERDE: An optional unary function used to deserialize message keys; defaults to SERDE.

* VALUE-SERDE: An optional unary function used to deserialize message values; defaults to SERDE.

Example:

(let ((consumer (make-instance
’kf:consumer
:conf ’("bootstrap.servers" "127.0.0.1:9092" "group.id" "consumer-group-id" "enable.auto.commit" "false" "auto.offset.reset" "earliest")
:serde #’babel:octets-to-string)))
(kf:subscribe consumer ’("topic-name"))

(loop
for message = (kf:poll consumer 2000)
while message

for key = (kf:key message)
for value = (kf:value message)

collect (list key value)

do (kf:commit consumer)))

Package

cl-rdkafka.

Source

consumer.lisp.

Direct methods
Direct slots
Slot: rd-kafka-consumer

Pointer to rd_kafka_t struct.

Slot: rd-kafka-queue

Pointer to rd_kafka_queue_t struct.

Slot: key-serde

DESERIALIZER to map byte vector to object.

Type

cl-rdkafka::deserializer

Slot: value-serde

DESERIALIZER to map byte vector to object.

Type

cl-rdkafka::deserializer

Class: future

A future to hold the result of an async operation.

Example:

(let ((future (kf:send producer "topic" "message"))) (kf:donep future) ;; => nil
(kf:value future) ;; => #<MESSAGE {1005BE9D23}> (kf:donep future) ;; => t

(let ((new-future (kf:then future
(lambda (message err) (when err
(error err)) (kf:value message))))) (kf:value new-future))) ;; => "message"

Package

cl-rdkafka.

Source

future.lisp.

Direct methods
Direct slots
Slot: promise

lparallel promise that backs this future object.

Initform

(error "must supply lparallel promise")

Initargs

:promise

Slot: client

Reference to a producer/consumer to prevent gc during promise fulfillment.

Type

(or cl-rdkafka:consumer cl-rdkafka:producer)

Initform

(error "must supply producer or consumer")

Initargs

:client

Class: message

A kafka message as returned by consumer’s poll or producer’s send.

Example:

(let ((message (kf:poll consumer 5000)))
(kf:key message)
;; => "key-1", #(107 101 121 45 49)

(kf:value message)
;; => "Hello", #(72 101 108 108 111)

(kf:topic message)
;; => "foobar"

(kf:partition message)
;; => 0

(kf:offset message)
;; => 0

(kf:timestamp message)
;; => 1577002478269, :CREATE-TIME

(kf:headers message)
;; => ’(("one" . #(1 2 3))
;; ("two" . #(4 5 6)))

)

Package

cl-rdkafka.

Source

message.lisp.

Direct methods
Direct slots
Slot: raw-key

Message’s serialized key as a byte vector.

Type

(and vector cl-rdkafka::byte-seq)

Initargs

:raw-key

Slot: raw-value

Message’s serialized value as a byte vector.

Type

(and vector cl-rdkafka::byte-seq)

Initargs

:raw-value

Slot: key

Message’s deserialized key.

Initargs

:key

Slot: value

Message’s deserialized value.

Initargs

:value

Slot: topic

The topic this message originated from.

Type

string

Initargs

:topic

Readers

topic.

Writers

This slot is read-only.

Slot: partition

The partition this message originated from.

Type

integer

Initargs

:partition

Readers

partition.

Writers

This slot is read-only.

Slot: offset

Message offset.

Type

integer

Initargs

:offset

Readers

offset.

Writers

This slot is read-only.

Slot: timestamp

Message timestamp measured in milliseconds since the UTC epoch, or nil.

Type

(or null integer)

Initargs

:timestamp

Slot: timestamp-type

Type of message timestamp, or nil.

Type

(member nil :create-time :log-append-time)

Initargs

:timestamp-type

Slot: latency

Message latency measured in microseconds from the send call, or nil.

Type

(or null integer)

Initargs

:latency

Slot: headers

Message headers as an alist, or nil.

Type

(or null list)

Initargs

:headers

Readers

headers.

Writers

This slot is read-only.

Class: producer

A client that produces messages to kafka topics.

MAKE-INSTANCE accepts the following keyword args:

* CONF: A required plist, alist, or hash-table mapping config keys to their respective values; both keys and values should be strings. The provided key-value pairs are passed as-is to librdkafka, so consult the librdkafka config docs for more info.

* SERDE: An optional unary function accepting an object and returning a byte sequence; defaults to #’identity.

* KEY-SERDE: An optional unary function used to serialize message keys; defaults to SERDE.

* VALUE-SERDE: An optional unary function used to serialize message values; defaults to SERDE.

Example:

(let ((producer (make-instance
’kf:producer
:conf ’("bootstrap.servers" "127.0.0.1:9092" "enable.idempotence" "true")
:serde #’babel:string-to-octets))
(messages ’(("key-1" "value-1")
("key-2" "value-2"))))
(loop
for (k v) in messages
do (kf:send producer "topic-name" v :key k))

(kf:flush producer))

Package

cl-rdkafka.

Source

producer.lisp.

Direct methods
Direct slots
Slot: rd-kafka-producer

Pointer to rd_kafka_t struct.

Slot: rd-kafka-queue

Pointer to rd_kafka_queue_t struct.

Slot: last-promise

Latest promise from send call.

Slot: key-serde

SERIALIZER to map object to byte sequence.

Type

cl-rdkafka::serializer

Slot: value-serde

SERIALIZER to map object to byte sequence.

Type

cl-rdkafka::serializer


6.2 Internals


Next: , Previous: , Up: Internals   [Contents][Index]

6.2.1 Constants

Constant: +errstr-len+

A lot of the cl-rdkafka/low-level functions accept a char pointer and len which is filled with an error message if anything goes wrong. This constant determines the length of the char buffer which we’ll malloc/free for such functions.

Package

cl-rdkafka.

Source

common.lisp.


Next: , Previous: , Up: Internals   [Contents][Index]

6.2.2 Special variables

Special Variable: +address->queue+

Maps an rd_kafka_queue_t pointer address to (function . queue).

Package

cl-rdkafka.

Source

kernel.lisp.

Special Variable: +address->queue-lock+
Package

cl-rdkafka.

Source

kernel.lisp.

Special Variable: +kernel+
Package

cl-rdkafka.

Source

kernel.lisp.

Special Variable: +pointer-size+

C pointer size in bytes.

Package

cl-rdkafka.

Source

kernel.lisp.

Special Variable: +read-fd+
Package

cl-rdkafka.

Source

kernel.lisp.

Special Variable: +write-fd+
Package

cl-rdkafka.

Source

kernel.lisp.


6.2.3 Macros

Macro: assert-successful-event (event result)
Package

cl-rdkafka.

Source

common.lisp.

Macro: def-admin-methods (name (&rest lambda-list) &body body)

Define two methods named NAME with the first arg of LAMBDA-LIST specialized to consumer and producer.

A POINTER symbol is bound to the rd-kafka-[consumer|producer] slot of the first LAMBDA-LIST arg for BODY to use.

Package

cl-rdkafka.

Source

common.lisp.

Macro: defcenum (name-and-options &body enum-list)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Macro: defcfun (name-and-options return-type &body args)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Macro: defcstruct (name-and-options &body fields)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Macro: defctype (name base-type &optional documentation)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Macro: event->result (event result)
Package

cl-rdkafka.

Source

common.lisp.

Macro: find-field-function (op field)
Package

cl-rdkafka.

Source

common.lisp.

Macro: find-function (format-template &rest format-args)
Package

cl-rdkafka.

Source

common.lisp.

Macro: find-result-function (op)
Package

cl-rdkafka.

Source

common.lisp.

Macro: foreach-toppar (toppar-list (&rest fields) &body body)

For each element in TOPPAR-LIST, BODY is evaluated under FIELDS bindings.

The symbols in FIELDS are bound to the corresponding fields of each TOPPAR-LIST element.

TOPPAR-LIST should be a pointer to a cl-rdkafka/ll:rd-kafka-topic-partition-list.

Package

cl-rdkafka.

Source

toppar.lisp.

Macro: make-loop (array-generating-form &body body)

Expands to a loop form that iterates over the results of ARRAY-GENERATING-FORM.

BODY is appended as the last lines of the expanded loop form and a
POINTER symbol is bound to each array elem for BODY to use.

Package

cl-rdkafka.

Source

common.lisp.

Macro: make-set-keyval (old-version-p)
Package

cl-rdkafka.

Source

conf.lisp.

Macro: perform-admin-op (op rd-kafka-client admin-options admin-object)
Package

cl-rdkafka.

Source

common.lisp.

Macro: with-conf (conf-pointer conf-mapping &body body)

Binds CONF-POINTER to output of CONF-MAPPING during BODY.

If BODY evaluates without signalling a condition, then it is expected to take ownership of CONF-POINTER. If a condition is signalled by BODY, however, then CONF-POINTER will be freed by this macro.

Package

cl-rdkafka.

Source

conf.lisp.

Macro: with-consumer-group-metadata (metadata consumer &body body)
Package

cl-rdkafka.

Source

producer.lisp.

Macro: with-set-keyval (set-keyval &body body)
Package

cl-rdkafka.

Source

conf.lisp.

Macro: with-toppar-list (symbol alloc-form &body body)
Package

cl-rdkafka.

Source

toppar.lisp.


Next: , Previous: , Up: Internals   [Contents][Index]

6.2.4 Ordinary functions

Function: %alter-config (rd-kafka-client name config timeout-ms)
Package

cl-rdkafka.

Source

config.lisp.

Function: %assignment (rd-kafka-consumer)
Package

cl-rdkafka.

Source

consumer.lisp.

Function: %cluster-metadata (rd-kafka-client all-topics topic-handle timeout-ms)
Package

cl-rdkafka.

Source

cluster-metadata.lisp.

Function: %commit (rd-kafka-consumer toppar-list rd-kafka-queue)
Package

cl-rdkafka.

Source

consumer.lisp.

Function: %create-partitions (rd-kafka-client topic partitions timeout-ms)
Package

cl-rdkafka.

Source

create-partitions.lisp.

Function: %create-topic (rd-kafka-client topic partitions replication-factor conf timeout-ms validate-only-p)
Package

cl-rdkafka.

Source

create-topic.lisp.

Function: %delete-topic (rd-kafka-client topic timeout-ms)
Package

cl-rdkafka.

Source

delete-topic.lisp.

Function: %describe-config (rd-kafka-client name type timeout-ms)
Package

cl-rdkafka.

Source

config.lisp.

Function: %group-info (rd-kafka-client group-pointer timeout-ms)
Package

cl-rdkafka.

Source

group-info.lisp.

Function: %seek (consumer topic partition offset timeout-ms)
Package

cl-rdkafka.

Source

consumer.lisp.

Function: %send (rd-kafka-producer topic partition key-bytes value-bytes headers timestamp)
Package

cl-rdkafka.

Source

producer.lisp.

Function: %send-offsets-to-transaction (producer consumer offsets timeout-ms)
Package

cl-rdkafka.

Source

producer.lisp.

Function: %subscription (rd-kafka-consumer)
Package

cl-rdkafka.

Source

consumer.lisp.

Function: add-header (headers name value)
Package

cl-rdkafka.

Source

producer.lisp.

Function: add-toppar (toppar-list topic partition offset metadata)
Package

cl-rdkafka.

Source

toppar.lisp.

Function: alloc-rd-kafka-conf ()
Package

cl-rdkafka.

Source

conf.lisp.

Function: alloc-rd-kafka-topic-conf ()
Package

cl-rdkafka.

Source

conf.lisp.

Function: alloc-toppar-list (seq &key topic partition offset metadata)

Returns a newly allocated cl-rdkafka/ll:rd-kafka-topic-partition-list initialized with the elements in SEQ.

The keyword args denote functions which will be applied to each element of SEQ to extract the corresponding cl-rdkafka/ll:rd-kafka-topic-partition struct field.

Package

cl-rdkafka.

Source

toppar.lisp.

Function: alloc-toppar-list-from-alist (seq)

Convenience wrapper for ALLOC-TOPPAR-LIST.

The elements of SEQ should look like either: * ((topic . partition) . (offset . metadata)) * ((topic . partition) . offset)

Package

cl-rdkafka.

Source

toppar.lisp.

Function: assert-expected-event (rd-kafka-event expected)
Package

cl-rdkafka.

Source

kernel.lisp.

Function: assert-good-revents (pollfd)
Package

cl-rdkafka.

Source

kernel.lisp.

Function: byte-seq-p (seq)
Package

cl-rdkafka.

Source

common.lisp.

Function: bytes->pointer (bytes)

Allocates and returns a new uint8 pointer to BYTES.

Package

cl-rdkafka.

Source

common.lisp.

Function: config-op-p (op)
Package

cl-rdkafka.

Source

common.lisp.

Function: deregister-rd-kafka-queue (rd-kafka-queue)
Package

cl-rdkafka.

Source

kernel.lisp.

Function: enable-event-io (rd-kafka-queue)
Package

cl-rdkafka.

Source

kernel.lisp.

Function: enqueue-payload (rd-kafka-queue payload)
Package

cl-rdkafka.

Source

kernel.lisp.

Function: error->condition (condition-type error)
Package

cl-rdkafka.

Source

conditions.lisp.

Function: get-config-data (rd-kafka-configresource)
Package

cl-rdkafka.

Source

common.lisp.

Function: get-good-commits-and-assert-no-bad-commits (rd-kafka-event)
Package

cl-rdkafka.

Source

consumer.lisp.

Function: get-headers (rd-kafka-message)
Package

cl-rdkafka.

Source

message.lisp.

Function: get-key (*rd-kafka-message)
Package

cl-rdkafka.

Source

message.lisp.

Function: get-latency (rd-kafka-message)
Package

cl-rdkafka.

Source

message.lisp.

Function: get-name (name-and-options)
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Function: get-payload (*rd-kafka-message)
Package

cl-rdkafka.

Source

message.lisp.

Function: get-synonyms (rd-kafka-configentry)
Package

cl-rdkafka.

Source

common.lisp.

Function: get-timestamp (rd-kafka-message)
Package

cl-rdkafka.

Source

message.lisp.

Function: get-topic (*rd-kafka-message)
Package

cl-rdkafka.

Source

message.lisp.

Function: giant-alist->decent-alist (giant-alist)
Package

cl-rdkafka.

Source

config.lisp.

Function: headers->alist (headers)
Package

cl-rdkafka.

Source

message.lisp.

Function: init-fds ()
Package

cl-rdkafka.

Source

kernel.lisp.

Function: init-kernel ()
Package

cl-rdkafka.

Source

kernel.lisp.

Function: make-admin-options (rd-kafka-client)
Package

cl-rdkafka.

Source

common.lisp.

Function: make-conf-from-alist (alist)
Package

cl-rdkafka.

Source

conf.lisp.

Function: make-conf-from-plist (plist)
Package

cl-rdkafka.

Source

conf.lisp.

Function: make-configresource (name type)
Package

cl-rdkafka.

Source

config.lisp.

Function: make-consumer-finalizer (rd-kafka-consumer rd-kafka-queue)
Package

cl-rdkafka.

Source

consumer.lisp.

Function: make-deletetopic (topic)
Package

cl-rdkafka.

Source

delete-topic.lisp.

Function: make-headers (alist)
Package

cl-rdkafka.

Source

producer.lisp.

Function: make-newpart (topic partitions errstr errstr-len)
Package

cl-rdkafka.

Source

create-partitions.lisp.

Function: make-newtopic (topic-name partitions replication-factor errstr errstr-len)
Package

cl-rdkafka.

Source

create-topic.lisp.

Function: make-partition-error (err topic partition)
Package

cl-rdkafka.

Source

conditions.lisp.

Function: make-producer-finalizer (rd-kafka-producer rd-kafka-queue)
Package

cl-rdkafka.

Source

producer.lisp.

Function: make-rd-kafka-queue (rd-kafka-client)
Package

cl-rdkafka.

Source

common.lisp.

Function: make-rdkafka-error (err)
Package

cl-rdkafka.

Source

conditions.lisp.

Function: make-topic (rd-kafka-client topic-name)
Package

cl-rdkafka.

Source

cluster-metadata.lisp.

Function: messages->toppar-list (messages)
Package

cl-rdkafka.

Source

producer.lisp.

Function: parse-broker-group-info (group-info)
Package

cl-rdkafka.

Source

group-info.lisp.

Function: parse-broker-metadata (metadata)

Return a list of (:id :host :port) alists.

Package

cl-rdkafka.

Source

cluster-metadata.lisp.

Function: parse-cluster-metadata (metadata)

Returns a (:originating-broker :broker-metadata :topic-metadata) alist.

Package

cl-rdkafka.

Source

cluster-metadata.lisp.

Function: parse-configentry (entry)
Package

cl-rdkafka.

Source

common.lisp.

Function: parse-group-info (group-info)
Package

cl-rdkafka.

Source

group-info.lisp.

Function: parse-group-list (group-list)
Package

cl-rdkafka.

Source

group-info.lisp.

Function: parse-member-info (member-info)
Package

cl-rdkafka.

Source

group-info.lisp.

Function: parse-members-group-info (group-info)
Package

cl-rdkafka.

Source

group-info.lisp.

Function: parse-partitions-metadata (topic-metadata)

Return a list of (:id :leader :replicas :in-sync-replicas) alists.

Package

cl-rdkafka.

Source

cluster-metadata.lisp.

Function: parse-timestamp-type (ts-type)
Package

cl-rdkafka.

Source

message.lisp.

Function: parse-topic-metadata (metadata)

Return a list of (:topic :partitions) alists.

Package

cl-rdkafka.

Source

cluster-metadata.lisp.

Function: pointer->bytes (pointer length)

Copies cffi :pointer bytes into a byte vector.

Package

cl-rdkafka.

Source

common.lisp.

Function: poll-loop ()
Package

cl-rdkafka.

Source

kernel.lisp.

Function: posix-close (fd)
Package

cl-rdkafka.

Source

posix.lisp.

Function: posix-pipe (fds)
Package

cl-rdkafka.

Source

posix.lisp.

Function: posix-poll (fds nfds timeout)
Package

cl-rdkafka.

Source

posix.lisp.

Function: posix-read (fd buf count)
Package

cl-rdkafka.

Source

posix.lisp.

Function: posix-write (fd buf count)
Package

cl-rdkafka.

Source

posix.lisp.

Function: process-commit-event (rd-kafka-event queue)
Package

cl-rdkafka.

Source

consumer.lisp.

Function: process-events (rd-kafka-queue)
Package

cl-rdkafka.

Source

kernel.lisp.

Function: process-send-event (rd-kafka-event queue)
Package

cl-rdkafka.

Source

producer.lisp.

Function: rd-kafka-message->message (rd-kafka-message key-function value-function)

Transform a struct rd-kafka-message pointer to a MESSAGE object.

KEY-FUNCTION and VALUE-FUNCTION are both unary functions that are expected to output the deserialized key/value given the serialized key/value.

Package

cl-rdkafka.

Source

message.lisp.

Function: read-rd-kafka-queue-from-fd (pollfd)
Package

cl-rdkafka.

Source

kernel.lisp.

Function: register-rd-kafka-queue (rd-kafka-queue process-event)
Package

cl-rdkafka.

Source

kernel.lisp.

Function: set-conf (newtopic conf)
Package

cl-rdkafka.

Source

create-topic.lisp.

Function: set-keyvals (configresource alist)
Package

cl-rdkafka.

Source

config.lisp.

Function: set-rd-kafka-conf (rd-kafka-conf key value errstr errstr-len)
Package

cl-rdkafka.

Source

conf.lisp.

Function: set-rd-kafka-topic-conf (rd-kafka-topic-conf key value errstr errstr-len)
Package

cl-rdkafka.

Source

conf.lisp.

Function: set-timeout (admin-options timeout-ms errstr errstr-len)
Package

cl-rdkafka.

Source

common.lisp.

Function: set-validate (admin-options validatep errstr errstr-len)
Package

cl-rdkafka.

Source

common.lisp.

Function: wait-for-fd (pollfd)
Package

cl-rdkafka.

Source

kernel.lisp.


Next: , Previous: , Up: Internals   [Contents][Index]

6.2.5 Generic functions

Generic Function: alter-config (client topic config &key timeout-ms)

Alter config of TOPIC according to CONFIG, reverting to defaults for unspecified configs.

Package

cl-rdkafka.

Source

config.lisp.

Methods
Method: alter-config ((client producer) (topic string) (config list) &key timeout-ms)
Method: alter-config ((client consumer) (topic string) (config list) &key timeout-ms)
Generic Function: apply-serde (serde arg)
Package

cl-rdkafka.

Source

serde.lisp.

Methods
Method: apply-serde ((serde serde) arg)
Generic Function: cluster-id (client &key timeout-ms)

Returns the cluster-id as reported in the broker metadata.

Package

cl-rdkafka.

Source

cluster-metadata.lisp.

Methods
Method: cluster-id ((client producer) &key timeout-ms)
Method: cluster-id ((client consumer) &key timeout-ms)
Generic Function: cluster-metadata (client topic &key timeout-ms)

Return an alist of cluster metadata.

TOPIC can be one of:
* a string indicating the topic name to return metadata for.
* :LOCAL, in which case metadata for only locally known topics is returned. * :ALL, in which case metadata for all cluster topics is returned.

The returned alist looks something like:
((:originating-broker . ((:id . 1001)
(:name . "127.0.0.1:9092/1001"))) (:broker-metadata . (((:id . 1001)
(:host . "127.0.0.1")
(:port . 9092))))
(:topic-metadata . (((:topic . "topic-name")
(:partitions . (((:id . 0)
(:leader . 1001)
(:replicas . (1001)) (:in-sync-replicas . (1001)))))))))

Package

cl-rdkafka.

Source

cluster-metadata.lisp.

Methods
Method: cluster-metadata ((client producer) (topic (eql :all)) &key timeout-ms)
Method: cluster-metadata ((client consumer) (topic (eql :all)) &key timeout-ms)
Method: cluster-metadata ((client producer) (topic (eql :local)) &key timeout-ms)
Method: cluster-metadata ((client consumer) (topic (eql :local)) &key timeout-ms)
Method: cluster-metadata ((client producer) (topic string) &key timeout-ms)
Method: cluster-metadata ((client consumer) (topic string) &key timeout-ms)
Generic Function: controller-id (client &key timeout-ms)

Returns the controller-id as reported in the broker metadata, or nil.

Package

cl-rdkafka.

Source

cluster-metadata.lisp.

Methods
Method: controller-id ((client producer) &key timeout-ms)
Method: controller-id ((client consumer) &key timeout-ms)
Generic Function: create-partitions (client topic partitions &key timeout-ms)

Increase TOPIC’s partition count up to PARTITIONS and return PARTITIONS on success.

Package

cl-rdkafka.

Source

create-partitions.lisp.

Methods
Method: create-partitions ((client producer) (topic string) (partitions fixnum) &key timeout-ms)
Method: create-partitions ((client consumer) (topic string) (partitions fixnum) &key timeout-ms)
Generic Function: create-topic (client topic &key partitions replication-factor conf timeout-ms validate-only-p)

Create topic TOPIC with given keyword args and return TOPIC on success.

If VALIDATE-ONLY-P is true, then the create topic request will be validated by the broker without the topic actually being created.

Package

cl-rdkafka.

Source

create-topic.lisp.

Methods
Method: create-topic ((client producer) (topic string) &key partitions replication-factor conf timeout-ms validate-only-p)
Method: create-topic ((client consumer) (topic string) &key partitions replication-factor conf timeout-ms validate-only-p)
Generic Function: delete-topic (client topic &key timeout-ms)

Delete topic TOPIC and return TOPIC on success.

Package

cl-rdkafka.

Source

delete-topic.lisp.

Methods
Method: delete-topic ((client producer) (topic string) &key timeout-ms)
Method: delete-topic ((client consumer) (topic string) &key timeout-ms)
Generic Function: describe-config (client name type &key timeout-ms)

Return an alist of config key-val pairs for NAME.

If TYPE is :BROKER, then NAME should be the broker-id, like "1001". If TYPE is :TOPIC, then NAME should be the topic-name.

Package

cl-rdkafka.

Source

config.lisp.

Methods
Method: describe-config ((client producer) (name string) (type (eql :broker)) &key timeout-ms)
Method: describe-config ((client consumer) (name string) (type (eql :broker)) &key timeout-ms)
Method: describe-config ((client producer) (name string) (type (eql :topic)) &key timeout-ms)
Method: describe-config ((client consumer) (name string) (type (eql :topic)) &key timeout-ms)
Generic Function: get-conf (client)

Return an alist describing the client config of CLIENT.

Package

cl-rdkafka.

Source

config.lisp.

Methods
Method: get-conf ((client producer))
Method: get-conf ((client consumer))
Generic Function: group-info (client group &key timeout-ms)

Return group info about GROUP as a list of alists.

The second boolean return value indicates if some brokers failed to respond in time.

GROUP can be either:
* a string indicating which group to return info for.
* nil, in which case info for all groups is returned.

Each alist looks something like:
((:GROUP . "clever-group-name-to-showcase-my-creative-personality") (:BROKER (:ID . 1001)
(:HOST . "127.0.0.1")
(:PORT . 9092))
(:STATE . "Stable")
(:PROTOCOL-TYPE . "consumer")
(:PROTOCOL . "range")
(:MEMBERS
((:ID . "rdkafka-b4af90cc-bd32-4b24-a0e6-cbad8f5888aa")
(:CLIENT-ID . "rdkafka")
(:CLIENT-HOST . "/172.18.0.1")
(:METADATA
. #(0 0 0 0 0 1 0 15 102 111 111 45 98 97 114 45 116 111 112 105 99 45 51 0 0 0 1 0 0 0 0 0 0 0 0))
(:ASSIGNMENT
. #(0 0 0 0 0 1 0 15 102 111 111 45 98 97 114 45 116 111 112 105 99 45 51 0 0 0 1 0 0 0 0 0 0 0 0)))))

Package

cl-rdkafka.

Source

group-info.lisp.

Methods
Method: group-info ((client producer) (group null) &key timeout-ms)
Method: group-info ((client consumer) (group null) &key timeout-ms)
Method: group-info ((client producer) (group string) &key timeout-ms)
Method: group-info ((client consumer) (group string) &key timeout-ms)
Generic Function: make-conf (map)
Package

cl-rdkafka.

Source

conf.lisp.

Methods
Method: make-conf ((map list))
Method: make-conf ((map hash-table))
Generic Function: serde-funcall (serde arg)
Package

cl-rdkafka.

Source

serde.lisp.

Methods
Method: serde-funcall ((serde deserializer) arg)
Method: serde-funcall ((serde serializer) arg)

Next: , Previous: , Up: Internals   [Contents][Index]

6.2.6 Classes

Class: deserializer
Package

cl-rdkafka.

Source

serde.lisp.

Direct superclasses

serde.

Direct methods

serde-funcall.

Class: pollfd-tclass
Package

cl-rdkafka.

Source

posix.lisp.

Direct superclasses
  • foreign-struct-type.
  • translatable-foreign-type.
Class: rd-kafka-err-desc-tclass
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Direct superclasses
  • foreign-struct-type.
  • translatable-foreign-type.
Class: rd-kafka-group-info-tclass
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Direct superclasses
  • foreign-struct-type.
  • translatable-foreign-type.
Class: rd-kafka-group-list-tclass
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Direct superclasses
  • foreign-struct-type.
  • translatable-foreign-type.
Class: rd-kafka-group-member-info-tclass
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Direct superclasses
  • foreign-struct-type.
  • translatable-foreign-type.
Class: rd-kafka-message-tclass
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Direct superclasses
  • foreign-struct-type.
  • translatable-foreign-type.
Class: rd-kafka-metadata-broker-tclass
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Direct superclasses
  • foreign-struct-type.
  • translatable-foreign-type.
Class: rd-kafka-metadata-partition-tclass
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Direct superclasses
  • foreign-struct-type.
  • translatable-foreign-type.
Class: rd-kafka-metadata-tclass
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Direct superclasses
  • foreign-struct-type.
  • translatable-foreign-type.
Class: rd-kafka-metadata-topic-tclass
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Direct superclasses
  • foreign-struct-type.
  • translatable-foreign-type.
Class: rd-kafka-topic-partition-list-tclass
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Direct superclasses
  • foreign-struct-type.
  • translatable-foreign-type.
Class: rd-kafka-topic-partition-tclass
Package

cl-rdkafka/low-level.

Source

librdkafka-bindings.lisp.

Direct superclasses
  • foreign-struct-type.
  • translatable-foreign-type.
Class: serde
Package

cl-rdkafka.

Source

serde.lisp.

Direct subclasses
Direct methods

apply-serde.

Direct slots
Slot: function
Package

common-lisp.

Type

function

Initform

(error "must supply function")

Initargs

:function

Slot: name
Type

string

Initform

(error "must supply name")

Initargs

:name

Class: serializer
Package

cl-rdkafka.

Source

serde.lisp.

Direct superclasses

serde.

Direct methods

serde-funcall.


Previous: , Up: Internals   [Contents][Index]

6.2.7 Types

Type: byte-seq ()
Package

cl-rdkafka.

Source

common.lisp.


Appendix A Indexes


Next: , Previous: , Up: Indexes   [Contents][Index]

A.1 Concepts


Next: , Previous: , Up: Indexes   [Contents][Index]

A.2 Functions

Jump to:   %  
A   B   C   D   E   F   G   H   I   K   M   N   O   P   R   S   T   U   V   W  
Index Entry  Section

%
%alter-config: Private ordinary functions
%assignment: Private ordinary functions
%cluster-metadata: Private ordinary functions
%commit: Private ordinary functions
%create-partitions: Private ordinary functions
%create-topic: Private ordinary functions
%delete-topic: Private ordinary functions
%describe-config: Private ordinary functions
%group-info: Private ordinary functions
%seek: Private ordinary functions
%send: Private ordinary functions
%send-offsets-to-transaction: Private ordinary functions
%subscription: Private ordinary functions

A
abort-transaction: Public generic functions
abort-transaction: Public generic functions
add-header: Private ordinary functions
add-toppar: Private ordinary functions
alloc-rd-kafka-conf: Private ordinary functions
alloc-rd-kafka-topic-conf: Private ordinary functions
alloc-toppar-list: Private ordinary functions
alloc-toppar-list-from-alist: Private ordinary functions
alter-config: Private generic functions
alter-config: Private generic functions
alter-config: Private generic functions
apply-serde: Private generic functions
apply-serde: Private generic functions
assert-expected-event: Private ordinary functions
assert-good-revents: Private ordinary functions
assert-successful-event: Private macros
assign: Public generic functions
assign: Public generic functions
assignment: Public generic functions
assignment: Public generic functions

B
baddies: Public generic functions
baddies: Public generic functions
begin-transaction: Public generic functions
begin-transaction: Public generic functions
byte-seq-p: Private ordinary functions
bytes->pointer: Private ordinary functions

C
close: Public generic functions
close: Public generic functions
cluster-id: Private generic functions
cluster-id: Private generic functions
cluster-id: Private generic functions
cluster-metadata: Private generic functions
cluster-metadata: Private generic functions
cluster-metadata: Private generic functions
cluster-metadata: Private generic functions
cluster-metadata: Private generic functions
cluster-metadata: Private generic functions
cluster-metadata: Private generic functions
commit: Public generic functions
commit: Public generic functions
commit-transaction: Public generic functions
commit-transaction: Public generic functions
committed: Public generic functions
committed: Public generic functions
config-op-p: Private ordinary functions
controller-id: Private generic functions
controller-id: Private generic functions
controller-id: Private generic functions
create-partitions: Private generic functions
create-partitions: Private generic functions
create-partitions: Private generic functions
create-topic: Private generic functions
create-topic: Private generic functions
create-topic: Private generic functions

D
def-admin-methods: Private macros
defcenum: Private macros
defcfun: Private macros
defcstruct: Private macros
defctype: Private macros
delete-topic: Private generic functions
delete-topic: Private generic functions
delete-topic: Private generic functions
deregister-rd-kafka-queue: Private ordinary functions
describe-config: Private generic functions
describe-config: Private generic functions
describe-config: Private generic functions
describe-config: Private generic functions
describe-config: Private generic functions
description: Public generic functions
description: Public generic functions
description: Public generic functions
donep: Public generic functions
donep: Public generic functions

E
enable-event-io: Private ordinary functions
enqueue-payload: Private ordinary functions
enum: Public generic functions
enum: Public generic functions
error->condition: Private ordinary functions
event->result: Private macros

F
find-field-function: Private macros
find-function: Private macros
find-result-function: Private macros
flush: Public generic functions
flush: Public generic functions
foreach-toppar: Private macros
Function, %alter-config: Private ordinary functions
Function, %assignment: Private ordinary functions
Function, %cluster-metadata: Private ordinary functions
Function, %commit: Private ordinary functions
Function, %create-partitions: Private ordinary functions
Function, %create-topic: Private ordinary functions
Function, %delete-topic: Private ordinary functions
Function, %describe-config: Private ordinary functions
Function, %group-info: Private ordinary functions
Function, %seek: Private ordinary functions
Function, %send: Private ordinary functions
Function, %send-offsets-to-transaction: Private ordinary functions
Function, %subscription: Private ordinary functions
Function, add-header: Private ordinary functions
Function, add-toppar: Private ordinary functions
Function, alloc-rd-kafka-conf: Private ordinary functions
Function, alloc-rd-kafka-topic-conf: Private ordinary functions
Function, alloc-toppar-list: Private ordinary functions
Function, alloc-toppar-list-from-alist: Private ordinary functions
Function, assert-expected-event: Private ordinary functions
Function, assert-good-revents: Private ordinary functions
Function, byte-seq-p: Private ordinary functions
Function, bytes->pointer: Private ordinary functions
Function, config-op-p: Private ordinary functions
Function, deregister-rd-kafka-queue: Private ordinary functions
Function, enable-event-io: Private ordinary functions
Function, enqueue-payload: Private ordinary functions
Function, error->condition: Private ordinary functions
Function, get-config-data: Private ordinary functions
Function, get-good-commits-and-assert-no-bad-commits: Private ordinary functions
Function, get-headers: Private ordinary functions
Function, get-key: Private ordinary functions
Function, get-latency: Private ordinary functions
Function, get-name: Private ordinary functions
Function, get-payload: Private ordinary functions
Function, get-synonyms: Private ordinary functions
Function, get-timestamp: Private ordinary functions
Function, get-topic: Private ordinary functions
Function, giant-alist->decent-alist: Private ordinary functions
Function, headers->alist: Private ordinary functions
Function, init-fds: Private ordinary functions
Function, init-kernel: Private ordinary functions
Function, make-admin-options: Private ordinary functions
Function, make-conf-from-alist: Private ordinary functions
Function, make-conf-from-plist: Private ordinary functions
Function, make-configresource: Private ordinary functions
Function, make-consumer-finalizer: Private ordinary functions
Function, make-deletetopic: Private ordinary functions
Function, make-headers: Private ordinary functions
Function, make-newpart: Private ordinary functions
Function, make-newtopic: Private ordinary functions
Function, make-partition-error: Private ordinary functions
Function, make-producer-finalizer: Private ordinary functions
Function, make-rd-kafka-queue: Private ordinary functions
Function, make-rdkafka-error: Private ordinary functions
Function, make-topic: Private ordinary functions
Function, messages->toppar-list: Private ordinary functions
Function, parse-broker-group-info: Private ordinary functions
Function, parse-broker-metadata: Private ordinary functions
Function, parse-cluster-metadata: Private ordinary functions
Function, parse-configentry: Private ordinary functions
Function, parse-group-info: Private ordinary functions
Function, parse-group-list: Private ordinary functions
Function, parse-member-info: Private ordinary functions
Function, parse-members-group-info: Private ordinary functions
Function, parse-partitions-metadata: Private ordinary functions
Function, parse-timestamp-type: Private ordinary functions
Function, parse-topic-metadata: Private ordinary functions
Function, pointer->bytes: Private ordinary functions
Function, poll-loop: Private ordinary functions
Function, posix-close: Private ordinary functions
Function, posix-pipe: Private ordinary functions
Function, posix-poll: Private ordinary functions
Function, posix-read: Private ordinary functions
Function, posix-write: Private ordinary functions
Function, process-commit-event: Private ordinary functions
Function, process-events: Private ordinary functions
Function, process-send-event: Private ordinary functions
Function, rd-kafka-abort-transaction: Public ordinary functions
Function, rd-kafka-adminoptions-destroy: Public ordinary functions
Function, rd-kafka-adminoptions-new: Public ordinary functions
Function, rd-kafka-adminoptions-set-broker: Public ordinary functions
Function, rd-kafka-adminoptions-set-opaque: Public ordinary functions
Function, rd-kafka-adminoptions-set-operation-timeout: Public ordinary functions
Function, rd-kafka-adminoptions-set-request-timeout: Public ordinary functions
Function, rd-kafka-adminoptions-set-validate-only: Public ordinary functions
Function, rd-kafka-alterconfigs: Public ordinary functions
Function, rd-kafka-alterconfigs-result-resources: Public ordinary functions
Function, rd-kafka-assign: Public ordinary functions
Function, rd-kafka-assignment: Public ordinary functions
Function, rd-kafka-begin-transaction: Public ordinary functions
Function, rd-kafka-brokers-add: Public ordinary functions
Function, rd-kafka-clusterid: Public ordinary functions
Function, rd-kafka-commit: Public ordinary functions
Function, rd-kafka-commit-message: Public ordinary functions
Function, rd-kafka-commit-queue: Public ordinary functions
Function, rd-kafka-commit-transaction: Public ordinary functions
Function, rd-kafka-committed: Public ordinary functions
Function, rd-kafka-conf: Public ordinary functions
Function, rd-kafka-conf-destroy: Public ordinary functions
Function, rd-kafka-conf-dump: Public ordinary functions
Function, rd-kafka-conf-dump-free: Public ordinary functions
Function, rd-kafka-conf-dup: Public ordinary functions
Function, rd-kafka-conf-dup-filter: Public ordinary functions
Function, rd-kafka-conf-get: Public ordinary functions
Function, rd-kafka-conf-interceptor-add-on-conf-destroy: Public ordinary functions
Function, rd-kafka-conf-interceptor-add-on-conf-dup: Public ordinary functions
Function, rd-kafka-conf-interceptor-add-on-conf-set: Public ordinary functions
Function, rd-kafka-conf-interceptor-add-on-new: Public ordinary functions
Function, rd-kafka-conf-new: Public ordinary functions
Function, rd-kafka-conf-properties-show: Public ordinary functions
Function, rd-kafka-conf-set: Public ordinary functions
Function, rd-kafka-conf-set-background-event-cb: Public ordinary functions
Function, rd-kafka-conf-set-closesocket-cb: Public ordinary functions
Function, rd-kafka-conf-set-connect-cb: Public ordinary functions
Function, rd-kafka-conf-set-consume-cb: Public ordinary functions
Function, rd-kafka-conf-set-default-topic-conf: Public ordinary functions
Function, rd-kafka-conf-set-dr-cb: Public ordinary functions
Function, rd-kafka-conf-set-dr-msg-cb: Public ordinary functions
Function, rd-kafka-conf-set-error-cb: Public ordinary functions
Function, rd-kafka-conf-set-events: Public ordinary functions
Function, rd-kafka-conf-set-log-cb: Public ordinary functions
Function, rd-kafka-conf-set-offset-commit-cb: Public ordinary functions
Function, rd-kafka-conf-set-opaque: Public ordinary functions
Function, rd-kafka-conf-set-open-cb: Public ordinary functions
Function, rd-kafka-conf-set-rebalance-cb: Public ordinary functions
Function, rd-kafka-conf-set-socket-cb: Public ordinary functions
Function, rd-kafka-conf-set-stats-cb: Public ordinary functions
Function, rd-kafka-conf-set-throttle-cb: Public ordinary functions
Function, rd-kafka-configentry-is-default: Public ordinary functions
Function, rd-kafka-configentry-is-read-only: Public ordinary functions
Function, rd-kafka-configentry-is-sensitive: Public ordinary functions
Function, rd-kafka-configentry-is-synonym: Public ordinary functions
Function, rd-kafka-configentry-name: Public ordinary functions
Function, rd-kafka-configentry-source: Public ordinary functions
Function, rd-kafka-configentry-synonyms: Public ordinary functions
Function, rd-kafka-configentry-value: Public ordinary functions
Function, rd-kafka-configresource-configs: Public ordinary functions
Function, rd-kafka-configresource-destroy: Public ordinary functions
Function, rd-kafka-configresource-destroy-array: Public ordinary functions
Function, rd-kafka-configresource-error: Public ordinary functions
Function, rd-kafka-configresource-error-string: Public ordinary functions
Function, rd-kafka-configresource-name: Public ordinary functions
Function, rd-kafka-configresource-new: Public ordinary functions
Function, rd-kafka-configresource-set-config: Public ordinary functions
Function, rd-kafka-configresource-type: Public ordinary functions
Function, rd-kafka-configsource-name: Public ordinary functions
Function, rd-kafka-consume: Public ordinary functions
Function, rd-kafka-consume-batch: Public ordinary functions
Function, rd-kafka-consume-batch-queue: Public ordinary functions
Function, rd-kafka-consume-callback: Public ordinary functions
Function, rd-kafka-consume-callback-queue: Public ordinary functions
Function, rd-kafka-consume-queue: Public ordinary functions
Function, rd-kafka-consume-start: Public ordinary functions
Function, rd-kafka-consume-start-queue: Public ordinary functions
Function, rd-kafka-consume-stop: Public ordinary functions
Function, rd-kafka-consumer-close: Public ordinary functions
Function, rd-kafka-consumer-group-metadata: Public ordinary functions
Function, rd-kafka-consumer-group-metadata-destroy: Public ordinary functions
Function, rd-kafka-consumer-group-metadata-new: Public ordinary functions
Function, rd-kafka-consumer-group-metadata-read: Public ordinary functions
Function, rd-kafka-consumer-group-metadata-write: Public ordinary functions
Function, rd-kafka-consumer-poll: Public ordinary functions
Function, rd-kafka-controllerid: Public ordinary functions
Function, rd-kafka-createpartitions: Public ordinary functions
Function, rd-kafka-createpartitions-result-topics: Public ordinary functions
Function, rd-kafka-createtopics: Public ordinary functions
Function, rd-kafka-createtopics-result-topics: Public ordinary functions
Function, rd-kafka-default-topic-conf-dup: Public ordinary functions
Function, rd-kafka-deletetopic-destroy: Public ordinary functions
Function, rd-kafka-deletetopic-destroy-array: Public ordinary functions
Function, rd-kafka-deletetopic-new: Public ordinary functions
Function, rd-kafka-deletetopics: Public ordinary functions
Function, rd-kafka-deletetopics-result-topics: Public ordinary functions
Function, rd-kafka-describeconfigs: Public ordinary functions
Function, rd-kafka-describeconfigs-result-resources: Public ordinary functions
Function, rd-kafka-destroy: Public ordinary functions
Function, rd-kafka-destroy-flags: Public ordinary functions
Function, rd-kafka-dump: Public ordinary functions
Function, rd-kafka-err2name: Public ordinary functions
Function, rd-kafka-err2str: Public ordinary functions
Function, rd-kafka-errno: Public ordinary functions
Function, rd-kafka-errno2err: Public ordinary functions
Function, rd-kafka-error-code: Public ordinary functions
Function, rd-kafka-error-destroy: Public ordinary functions
Function, rd-kafka-error-is-fatal: Public ordinary functions
Function, rd-kafka-error-is-retriable: Public ordinary functions
Function, rd-kafka-error-name: Public ordinary functions
Function, rd-kafka-error-string: Public ordinary functions
Function, rd-kafka-error-txn-requires-abort: Public ordinary functions
Function, rd-kafka-event-alterconfigs-result: Public ordinary functions
Function, rd-kafka-event-createpartitions-result: Public ordinary functions
Function, rd-kafka-event-createtopics-result: Public ordinary functions
Function, rd-kafka-event-debug-contexts: Public ordinary functions
Function, rd-kafka-event-deletetopics-result: Public ordinary functions
Function, rd-kafka-event-describeconfigs-result: Public ordinary functions
Function, rd-kafka-event-destroy: Public ordinary functions
Function, rd-kafka-event-error: Public ordinary functions
Function, rd-kafka-event-error-is-fatal: Public ordinary functions
Function, rd-kafka-event-error-string: Public ordinary functions
Function, rd-kafka-event-log: Public ordinary functions
Function, rd-kafka-event-message-array: Public ordinary functions
Function, rd-kafka-event-message-count: Public ordinary functions
Function, rd-kafka-event-message-next: Public ordinary functions
Function, rd-kafka-event-name: Public ordinary functions
Function, rd-kafka-event-opaque: Public ordinary functions
Function, rd-kafka-event-stats: Public ordinary functions
Function, rd-kafka-event-topic-partition: Public ordinary functions
Function, rd-kafka-event-topic-partition-list: Public ordinary functions
Function, rd-kafka-event-type: Public ordinary functions
Function, rd-kafka-fatal-error: Public ordinary functions
Function, rd-kafka-flush: Public ordinary functions
Function, rd-kafka-get-debug-contexts: Public ordinary functions
Function, rd-kafka-get-err-descs: Public ordinary functions
Function, rd-kafka-get-watermark-offsets: Public ordinary functions
Function, rd-kafka-group-list-destroy: Public ordinary functions
Function, rd-kafka-header-add: Public ordinary functions
Function, rd-kafka-header-cnt: Public ordinary functions
Function, rd-kafka-header-get: Public ordinary functions
Function, rd-kafka-header-get-all: Public ordinary functions
Function, rd-kafka-header-get-last: Public ordinary functions
Function, rd-kafka-header-remove: Public ordinary functions
Function, rd-kafka-headers-copy: Public ordinary functions
Function, rd-kafka-headers-destroy: Public ordinary functions
Function, rd-kafka-headers-new: Public ordinary functions
Function, rd-kafka-init-transactions: Public ordinary functions
Function, rd-kafka-interceptor-add-on-acknowledgement: Public ordinary functions
Function, rd-kafka-interceptor-add-on-commit: Public ordinary functions
Function, rd-kafka-interceptor-add-on-consume: Public ordinary functions
Function, rd-kafka-interceptor-add-on-destroy: Public ordinary functions
Function, rd-kafka-interceptor-add-on-request-sent: Public ordinary functions
Function, rd-kafka-interceptor-add-on-send: Public ordinary functions
Function, rd-kafka-last-error: Public ordinary functions
Function, rd-kafka-list-groups: Public ordinary functions
Function, rd-kafka-log-print: Public ordinary functions
Function, rd-kafka-log-syslog: Public ordinary functions
Function, rd-kafka-mem-free: Public ordinary functions
Function, rd-kafka-memberid: Public ordinary functions
Function, rd-kafka-message->message: Private ordinary functions
Function, rd-kafka-message-destroy: Public ordinary functions
Function, rd-kafka-message-detach-headers: Public ordinary functions
Function, rd-kafka-message-headers: Public ordinary functions
Function, rd-kafka-message-latency: Public ordinary functions
Function, rd-kafka-message-set-headers: Public ordinary functions
Function, rd-kafka-message-status: Public ordinary functions
Function, rd-kafka-message-timestamp: Public ordinary functions
Function, rd-kafka-metadata: Public ordinary functions
Function, rd-kafka-metadata-destroy: Public ordinary functions
Function, rd-kafka-msg-partitioner-consistent: Public ordinary functions
Function, rd-kafka-msg-partitioner-consistent-random: Public ordinary functions
Function, rd-kafka-msg-partitioner-murmur2: Public ordinary functions
Function, rd-kafka-msg-partitioner-murmur2-random: Public ordinary functions
Function, rd-kafka-msg-partitioner-random: Public ordinary functions
Function, rd-kafka-name: Public ordinary functions
Function, rd-kafka-new: Public ordinary functions
Function, rd-kafka-newpartitions-destroy: Public ordinary functions
Function, rd-kafka-newpartitions-destroy-array: Public ordinary functions
Function, rd-kafka-newpartitions-new: Public ordinary functions
Function, rd-kafka-newpartitions-set-replica-assignment: Public ordinary functions
Function, rd-kafka-newtopic-destroy: Public ordinary functions
Function, rd-kafka-newtopic-destroy-array: Public ordinary functions
Function, rd-kafka-newtopic-new: Public ordinary functions
Function, rd-kafka-newtopic-set-config: Public ordinary functions
Function, rd-kafka-newtopic-set-replica-assignment: Public ordinary functions
Function, rd-kafka-offset-store: Public ordinary functions
Function, rd-kafka-offsets-for-times: Public ordinary functions
Function, rd-kafka-offsets-store: Public ordinary functions
Function, rd-kafka-opaque: Public ordinary functions
Function, rd-kafka-outq-len: Public ordinary functions
Function, rd-kafka-pause-partitions: Public ordinary functions
Function, rd-kafka-poll: Public ordinary functions
Function, rd-kafka-poll-set-consumer: Public ordinary functions
Function, rd-kafka-position: Public ordinary functions
Function, rd-kafka-produce: Public ordinary functions
Function, rd-kafka-produce-batch: Public ordinary functions
Function, rd-kafka-purge: Public ordinary functions
Function, rd-kafka-query-watermark-offsets: Public ordinary functions
Function, rd-kafka-queue-cb-event-enable: Public ordinary functions
Function, rd-kafka-queue-destroy: Public ordinary functions
Function, rd-kafka-queue-forward: Public ordinary functions
Function, rd-kafka-queue-get-background: Public ordinary functions
Function, rd-kafka-queue-get-consumer: Public ordinary functions
Function, rd-kafka-queue-get-main: Public ordinary functions
Function, rd-kafka-queue-get-partition: Public ordinary functions
Function, rd-kafka-queue-io-event-enable: Public ordinary functions
Function, rd-kafka-queue-length: Public ordinary functions
Function, rd-kafka-queue-new: Public ordinary functions
Function, rd-kafka-queue-poll: Public ordinary functions
Function, rd-kafka-queue-poll-callback: Public ordinary functions
Function, rd-kafka-resourcetype-name: Public ordinary functions
Function, rd-kafka-resume-partitions: Public ordinary functions
Function, rd-kafka-seek: Public ordinary functions
Function, rd-kafka-send-offsets-to-transaction: Public ordinary functions
Function, rd-kafka-set-log-level: Public ordinary functions
Function, rd-kafka-set-log-queue: Public ordinary functions
Function, rd-kafka-set-logger: Public ordinary functions
Function, rd-kafka-subscribe: Public ordinary functions
Function, rd-kafka-subscription: Public ordinary functions
Function, rd-kafka-test-fatal-error: Public ordinary functions
Function, rd-kafka-thread-cnt: Public ordinary functions
Function, rd-kafka-topic-conf-destroy: Public ordinary functions
Function, rd-kafka-topic-conf-dump: Public ordinary functions
Function, rd-kafka-topic-conf-dup: Public ordinary functions
Function, rd-kafka-topic-conf-get: Public ordinary functions
Function, rd-kafka-topic-conf-new: Public ordinary functions
Function, rd-kafka-topic-conf-set: Public ordinary functions
Function, rd-kafka-topic-conf-set-msg-order-cmp: Public ordinary functions
Function, rd-kafka-topic-conf-set-opaque: Public ordinary functions
Function, rd-kafka-topic-conf-set-partitioner-cb: Public ordinary functions
Function, rd-kafka-topic-destroy: Public ordinary functions
Function, rd-kafka-topic-name: Public ordinary functions
Function, rd-kafka-topic-new: Public ordinary functions
Function, rd-kafka-topic-opaque: Public ordinary functions
Function, rd-kafka-topic-partition-available: Public ordinary functions
Function, rd-kafka-topic-partition-destroy: Public ordinary functions
Function, rd-kafka-topic-partition-list-add: Public ordinary functions
Function, rd-kafka-topic-partition-list-add-range: Public ordinary functions
Function, rd-kafka-topic-partition-list-copy: Public ordinary functions
Function, rd-kafka-topic-partition-list-del: Public ordinary functions
Function, rd-kafka-topic-partition-list-del-by-idx: Public ordinary functions
Function, rd-kafka-topic-partition-list-destroy: Public ordinary functions
Function, rd-kafka-topic-partition-list-find: Public ordinary functions
Function, rd-kafka-topic-partition-list-new: Public ordinary functions
Function, rd-kafka-topic-partition-list-set-offset: Public ordinary functions
Function, rd-kafka-topic-partition-list-sort: Public ordinary functions
Function, rd-kafka-topic-result-error: Public ordinary functions
Function, rd-kafka-topic-result-error-string: Public ordinary functions
Function, rd-kafka-topic-result-name: Public ordinary functions
Function, rd-kafka-type: Public ordinary functions
Function, rd-kafka-unittest: Public ordinary functions
Function, rd-kafka-unsubscribe: Public ordinary functions
Function, rd-kafka-version: Public ordinary functions
Function, rd-kafka-version-str: Public ordinary functions
Function, rd-kafka-wait-destroyed: Public ordinary functions
Function, rd-kafka-yield: Public ordinary functions
Function, read-rd-kafka-queue-from-fd: Private ordinary functions
Function, register-rd-kafka-queue: Private ordinary functions
Function, set-conf: Private ordinary functions
Function, set-keyvals: Private ordinary functions
Function, set-rd-kafka-conf: Private ordinary functions
Function, set-rd-kafka-topic-conf: Private ordinary functions
Function, set-timeout: Private ordinary functions
Function, set-validate: Private ordinary functions
Function, wait-for-fd: Private ordinary functions

G
Generic Function, abort-transaction: Public generic functions
Generic Function, alter-config: Private generic functions
Generic Function, apply-serde: Private generic functions
Generic Function, assign: Public generic functions
Generic Function, assignment: Public generic functions
Generic Function, baddies: Public generic functions
Generic Function, begin-transaction: Public generic functions
Generic Function, close: Public generic functions
Generic Function, cluster-id: Private generic functions
Generic Function, cluster-metadata: Private generic functions
Generic Function, commit: Public generic functions
Generic Function, commit-transaction: Public generic functions
Generic Function, committed: Public generic functions
Generic Function, controller-id: Private generic functions
Generic Function, create-partitions: Private generic functions
Generic Function, create-topic: Private generic functions
Generic Function, delete-topic: Private generic functions
Generic Function, describe-config: Private generic functions
Generic Function, description: Public generic functions
Generic Function, donep: Public generic functions
Generic Function, enum: Public generic functions
Generic Function, flush: Public generic functions
Generic Function, get-conf: Private generic functions
Generic Function, goodies: Public generic functions
Generic Function, group-info: Private generic functions
Generic Function, headers: Public generic functions
Generic Function, initialize-transactions: Public generic functions
Generic Function, key: Public generic functions
Generic Function, make-conf: Private generic functions
Generic Function, member-id: Public generic functions
Generic Function, name: Public generic functions
Generic Function, offset: Public generic functions
Generic Function, offsets-for-times: Public generic functions
Generic Function, partition: Public generic functions
Generic Function, pause: Public generic functions
Generic Function, poll: Public generic functions
Generic Function, positions: Public generic functions
Generic Function, resume: Public generic functions
Generic Function, seek: Public generic functions
Generic Function, seek-to-beginning: Public generic functions
Generic Function, seek-to-end: Public generic functions
Generic Function, send: Public generic functions
Generic Function, send-offsets-to-transaction: Public generic functions
Generic Function, serde-funcall: Private generic functions
Generic Function, subscribe: Public generic functions
Generic Function, subscription: Public generic functions
Generic Function, then: Public generic functions
Generic Function, timestamp: Public generic functions
Generic Function, topic: Public generic functions
Generic Function, unsubscribe: Public generic functions
Generic Function, value: Public generic functions
Generic Function, watermarks: Public generic functions
get-conf: Private generic functions
get-conf: Private generic functions
get-conf: Private generic functions
get-config-data: Private ordinary functions
get-good-commits-and-assert-no-bad-commits: Private ordinary functions
get-headers: Private ordinary functions
get-key: Private ordinary functions
get-latency: Private ordinary functions
get-name: Private ordinary functions
get-payload: Private ordinary functions
get-synonyms: Private ordinary functions
get-timestamp: Private ordinary functions
get-topic: Private ordinary functions
giant-alist->decent-alist: Private ordinary functions
goodies: Public generic functions
goodies: Public generic functions
group-info: Private generic functions
group-info: Private generic functions
group-info: Private generic functions
group-info: Private generic functions
group-info: Private generic functions

H
headers: Public generic functions
headers: Public generic functions
headers->alist: Private ordinary functions

I
init-fds: Private ordinary functions
init-kernel: Private ordinary functions
initialize-instance: Public standalone methods
initialize-instance: Public standalone methods
initialize-transactions: Public generic functions
initialize-transactions: Public generic functions

K
key: Public generic functions
key: Public generic functions

M
Macro, assert-successful-event: Private macros
Macro, def-admin-methods: Private macros
Macro, defcenum: Private macros
Macro, defcfun: Private macros
Macro, defcstruct: Private macros
Macro, defctype: Private macros
Macro, event->result: Private macros
Macro, find-field-function: Private macros
Macro, find-function: Private macros
Macro, find-result-function: Private macros
Macro, foreach-toppar: Private macros
Macro, make-loop: Private macros
Macro, make-set-keyval: Private macros
Macro, perform-admin-op: Private macros
Macro, rd-kafka-error-new: Public macros
Macro, rd-kafka-producev: Public macros
Macro, with-conf: Private macros
Macro, with-consumer-group-metadata: Private macros
Macro, with-set-keyval: Private macros
Macro, with-toppar-list: Private macros
make-admin-options: Private ordinary functions
make-conf: Private generic functions
make-conf: Private generic functions
make-conf: Private generic functions
make-conf-from-alist: Private ordinary functions
make-conf-from-plist: Private ordinary functions
make-configresource: Private ordinary functions
make-consumer-finalizer: Private ordinary functions
make-deletetopic: Private ordinary functions
make-headers: Private ordinary functions
make-loop: Private macros
make-newpart: Private ordinary functions
make-newtopic: Private ordinary functions
make-partition-error: Private ordinary functions
make-producer-finalizer: Private ordinary functions
make-rd-kafka-queue: Private ordinary functions
make-rdkafka-error: Private ordinary functions
make-set-keyval: Private macros
make-topic: Private ordinary functions
member-id: Public generic functions
member-id: Public generic functions
messages->toppar-list: Private ordinary functions
Method, abort-transaction: Public generic functions
Method, alter-config: Private generic functions
Method, alter-config: Private generic functions
Method, apply-serde: Private generic functions
Method, assign: Public generic functions
Method, assignment: Public generic functions
Method, baddies: Public generic functions
Method, begin-transaction: Public generic functions
Method, close: Public generic functions
Method, cluster-id: Private generic functions
Method, cluster-id: Private generic functions
Method, cluster-metadata: Private generic functions
Method, cluster-metadata: Private generic functions
Method, cluster-metadata: Private generic functions
Method, cluster-metadata: Private generic functions
Method, cluster-metadata: Private generic functions
Method, cluster-metadata: Private generic functions
Method, commit: Public generic functions
Method, commit-transaction: Public generic functions
Method, committed: Public generic functions
Method, controller-id: Private generic functions
Method, controller-id: Private generic functions
Method, create-partitions: Private generic functions
Method, create-partitions: Private generic functions
Method, create-topic: Private generic functions
Method, create-topic: Private generic functions
Method, delete-topic: Private generic functions
Method, delete-topic: Private generic functions
Method, describe-config: Private generic functions
Method, describe-config: Private generic functions
Method, describe-config: Private generic functions
Method, describe-config: Private generic functions
Method, description: Public generic functions
Method, description: Public generic functions
Method, donep: Public generic functions
Method, enum: Public generic functions
Method, flush: Public generic functions
Method, get-conf: Private generic functions
Method, get-conf: Private generic functions
Method, goodies: Public generic functions
Method, group-info: Private generic functions
Method, group-info: Private generic functions
Method, group-info: Private generic functions
Method, group-info: Private generic functions
Method, headers: Public generic functions
Method, initialize-instance: Public standalone methods
Method, initialize-instance: Public standalone methods
Method, initialize-transactions: Public generic functions
Method, key: Public generic functions
Method, make-conf: Private generic functions
Method, make-conf: Private generic functions
Method, member-id: Public generic functions
Method, name: Public generic functions
Method, offset: Public generic functions
Method, offsets-for-times: Public generic functions
Method, partition: Public generic functions
Method, partition: Public generic functions
Method, pause: Public generic functions
Method, poll: Public generic functions
Method, positions: Public generic functions
Method, resume: Public generic functions
Method, seek: Public generic functions
Method, seek-to-beginning: Public generic functions
Method, seek-to-end: Public generic functions
Method, send: Public generic functions
Method, send-offsets-to-transaction: Public generic functions
Method, send-offsets-to-transaction: Public generic functions
Method, send-offsets-to-transaction: Public generic functions
Method, serde-funcall: Private generic functions
Method, serde-funcall: Private generic functions
Method, subscribe: Public generic functions
Method, subscribe: Public generic functions
Method, subscription: Public generic functions
Method, then: Public generic functions
Method, timestamp: Public generic functions
Method, topic: Public generic functions
Method, topic: Public generic functions
Method, unsubscribe: Public generic functions
Method, value: Public generic functions
Method, value: Public generic functions
Method, watermarks: Public generic functions

N
name: Public generic functions
name: Public generic functions

O
offset: Public generic functions
offset: Public generic functions
offsets-for-times: Public generic functions
offsets-for-times: Public generic functions

P
parse-broker-group-info: Private ordinary functions
parse-broker-metadata: Private ordinary functions
parse-cluster-metadata: Private ordinary functions
parse-configentry: Private ordinary functions
parse-group-info: Private ordinary functions
parse-group-list: Private ordinary functions
parse-member-info: Private ordinary functions
parse-members-group-info: Private ordinary functions
parse-partitions-metadata: Private ordinary functions
parse-timestamp-type: Private ordinary functions
parse-topic-metadata: Private ordinary functions
partition: Public generic functions
partition: Public generic functions
partition: Public generic functions
pause: Public generic functions
pause: Public generic functions
perform-admin-op: Private macros
pointer->bytes: Private ordinary functions
poll: Public generic functions
poll: Public generic functions
poll-loop: Private ordinary functions
positions: Public generic functions
positions: Public generic functions
posix-close: Private ordinary functions
posix-pipe: Private ordinary functions
posix-poll: Private ordinary functions
posix-read: Private ordinary functions
posix-write: Private ordinary functions
process-commit-event: Private ordinary functions
process-events: Private ordinary functions
process-send-event: Private ordinary functions

R
rd-kafka-abort-transaction: Public ordinary functions
rd-kafka-adminoptions-destroy: Public ordinary functions
rd-kafka-adminoptions-new: Public ordinary functions
rd-kafka-adminoptions-set-broker: Public ordinary functions
rd-kafka-adminoptions-set-opaque: Public ordinary functions
rd-kafka-adminoptions-set-operation-timeout: Public ordinary functions
rd-kafka-adminoptions-set-request-timeout: Public ordinary functions
rd-kafka-adminoptions-set-validate-only: Public ordinary functions
rd-kafka-alterconfigs: Public ordinary functions
rd-kafka-alterconfigs-result-resources: Public ordinary functions
rd-kafka-assign: Public ordinary functions
rd-kafka-assignment: Public ordinary functions
rd-kafka-begin-transaction: Public ordinary functions
rd-kafka-brokers-add: Public ordinary functions
rd-kafka-clusterid: Public ordinary functions
rd-kafka-commit: Public ordinary functions
rd-kafka-commit-message: Public ordinary functions
rd-kafka-commit-queue: Public ordinary functions
rd-kafka-commit-transaction: Public ordinary functions
rd-kafka-committed: Public ordinary functions
rd-kafka-conf: Public ordinary functions
rd-kafka-conf-destroy: Public ordinary functions
rd-kafka-conf-dump: Public ordinary functions
rd-kafka-conf-dump-free: Public ordinary functions
rd-kafka-conf-dup: Public ordinary functions
rd-kafka-conf-dup-filter: Public ordinary functions
rd-kafka-conf-get: Public ordinary functions
rd-kafka-conf-interceptor-add-on-conf-destroy: Public ordinary functions
rd-kafka-conf-interceptor-add-on-conf-dup: Public ordinary functions
rd-kafka-conf-interceptor-add-on-conf-set: Public ordinary functions
rd-kafka-conf-interceptor-add-on-new: Public ordinary functions
rd-kafka-conf-new: Public ordinary functions
rd-kafka-conf-properties-show: Public ordinary functions
rd-kafka-conf-set: Public ordinary functions
rd-kafka-conf-set-background-event-cb: Public ordinary functions
rd-kafka-conf-set-closesocket-cb: Public ordinary functions
rd-kafka-conf-set-connect-cb: Public ordinary functions
rd-kafka-conf-set-consume-cb: Public ordinary functions
rd-kafka-conf-set-default-topic-conf: Public ordinary functions
rd-kafka-conf-set-dr-cb: Public ordinary functions
rd-kafka-conf-set-dr-msg-cb: Public ordinary functions
rd-kafka-conf-set-error-cb: Public ordinary functions
rd-kafka-conf-set-events: Public ordinary functions
rd-kafka-conf-set-log-cb: Public ordinary functions
rd-kafka-conf-set-offset-commit-cb: Public ordinary functions
rd-kafka-conf-set-opaque: Public ordinary functions
rd-kafka-conf-set-open-cb: Public ordinary functions
rd-kafka-conf-set-rebalance-cb: Public ordinary functions
rd-kafka-conf-set-socket-cb: Public ordinary functions
rd-kafka-conf-set-stats-cb: Public ordinary functions
rd-kafka-conf-set-throttle-cb: Public ordinary functions
rd-kafka-configentry-is-default: Public ordinary functions
rd-kafka-configentry-is-read-only: Public ordinary functions
rd-kafka-configentry-is-sensitive: Public ordinary functions
rd-kafka-configentry-is-synonym: Public ordinary functions
rd-kafka-configentry-name: Public ordinary functions
rd-kafka-configentry-source: Public ordinary functions
rd-kafka-configentry-synonyms: Public ordinary functions
rd-kafka-configentry-value: Public ordinary functions
rd-kafka-configresource-configs: Public ordinary functions
rd-kafka-configresource-destroy: Public ordinary functions
rd-kafka-configresource-destroy-array: Public ordinary functions
rd-kafka-configresource-error: Public ordinary functions
rd-kafka-configresource-error-string: Public ordinary functions
rd-kafka-configresource-name: Public ordinary functions
rd-kafka-configresource-new: Public ordinary functions
rd-kafka-configresource-set-config: Public ordinary functions
rd-kafka-configresource-type: Public ordinary functions
rd-kafka-configsource-name: Public ordinary functions
rd-kafka-consume: Public ordinary functions
rd-kafka-consume-batch: Public ordinary functions
rd-kafka-consume-batch-queue: Public ordinary functions
rd-kafka-consume-callback: Public ordinary functions
rd-kafka-consume-callback-queue: Public ordinary functions
rd-kafka-consume-queue: Public ordinary functions
rd-kafka-consume-start: Public ordinary functions
rd-kafka-consume-start-queue: Public ordinary functions
rd-kafka-consume-stop: Public ordinary functions
rd-kafka-consumer-close: Public ordinary functions
rd-kafka-consumer-group-metadata: Public ordinary functions
rd-kafka-consumer-group-metadata-destroy: Public ordinary functions
rd-kafka-consumer-group-metadata-new: Public ordinary functions
rd-kafka-consumer-group-metadata-read: Public ordinary functions
rd-kafka-consumer-group-metadata-write: Public ordinary functions
rd-kafka-consumer-poll: Public ordinary functions
rd-kafka-controllerid: Public ordinary functions
rd-kafka-createpartitions: Public ordinary functions
rd-kafka-createpartitions-result-topics: Public ordinary functions
rd-kafka-createtopics: Public ordinary functions
rd-kafka-createtopics-result-topics: Public ordinary functions
rd-kafka-default-topic-conf-dup: Public ordinary functions
rd-kafka-deletetopic-destroy: Public ordinary functions
rd-kafka-deletetopic-destroy-array: Public ordinary functions
rd-kafka-deletetopic-new: Public ordinary functions
rd-kafka-deletetopics: Public ordinary functions
rd-kafka-deletetopics-result-topics: Public ordinary functions
rd-kafka-describeconfigs: Public ordinary functions
rd-kafka-describeconfigs-result-resources: Public ordinary functions
rd-kafka-destroy: Public ordinary functions
rd-kafka-destroy-flags: Public ordinary functions
rd-kafka-dump: Public ordinary functions
rd-kafka-err2name: Public ordinary functions
rd-kafka-err2str: Public ordinary functions
rd-kafka-errno: Public ordinary functions
rd-kafka-errno2err: Public ordinary functions
rd-kafka-error-code: Public ordinary functions
rd-kafka-error-destroy: Public ordinary functions
rd-kafka-error-is-fatal: Public ordinary functions
rd-kafka-error-is-retriable: Public ordinary functions
rd-kafka-error-name: Public ordinary functions
rd-kafka-error-new: Public macros
rd-kafka-error-string: Public ordinary functions
rd-kafka-error-txn-requires-abort: Public ordinary functions
rd-kafka-event-alterconfigs-result: Public ordinary functions
rd-kafka-event-createpartitions-result: Public ordinary functions
rd-kafka-event-createtopics-result: Public ordinary functions
rd-kafka-event-debug-contexts: Public ordinary functions
rd-kafka-event-deletetopics-result: Public ordinary functions
rd-kafka-event-describeconfigs-result: Public ordinary functions
rd-kafka-event-destroy: Public ordinary functions
rd-kafka-event-error: Public ordinary functions
rd-kafka-event-error-is-fatal: Public ordinary functions
rd-kafka-event-error-string: Public ordinary functions
rd-kafka-event-log: Public ordinary functions
rd-kafka-event-message-array: Public ordinary functions
rd-kafka-event-message-count: Public ordinary functions
rd-kafka-event-message-next: Public ordinary functions
rd-kafka-event-name: Public ordinary functions
rd-kafka-event-opaque: Public ordinary functions
rd-kafka-event-stats: Public ordinary functions
rd-kafka-event-topic-partition: Public ordinary functions
rd-kafka-event-topic-partition-list: Public ordinary functions
rd-kafka-event-type: Public ordinary functions
rd-kafka-fatal-error: Public ordinary functions
rd-kafka-flush: Public ordinary functions
rd-kafka-get-debug-contexts: Public ordinary functions
rd-kafka-get-err-descs: Public ordinary functions
rd-kafka-get-watermark-offsets: Public ordinary functions
rd-kafka-group-list-destroy: Public ordinary functions
rd-kafka-header-add: Public ordinary functions
rd-kafka-header-cnt: Public ordinary functions
rd-kafka-header-get: Public ordinary functions
rd-kafka-header-get-all: Public ordinary functions
rd-kafka-header-get-last: Public ordinary functions
rd-kafka-header-remove: Public ordinary functions
rd-kafka-headers-copy: Public ordinary functions
rd-kafka-headers-destroy: Public ordinary functions
rd-kafka-headers-new: Public ordinary functions
rd-kafka-init-transactions: Public ordinary functions
rd-kafka-interceptor-add-on-acknowledgement: Public ordinary functions
rd-kafka-interceptor-add-on-commit: Public ordinary functions
rd-kafka-interceptor-add-on-consume: Public ordinary functions
rd-kafka-interceptor-add-on-destroy: Public ordinary functions
rd-kafka-interceptor-add-on-request-sent: Public ordinary functions
rd-kafka-interceptor-add-on-send: Public ordinary functions
rd-kafka-last-error: Public ordinary functions
rd-kafka-list-groups: Public ordinary functions
rd-kafka-log-print: Public ordinary functions
rd-kafka-log-syslog: Public ordinary functions
rd-kafka-mem-free: Public ordinary functions
rd-kafka-memberid: Public ordinary functions
rd-kafka-message->message: Private ordinary functions
rd-kafka-message-destroy: Public ordinary functions
rd-kafka-message-detach-headers: Public ordinary functions
rd-kafka-message-headers: Public ordinary functions
rd-kafka-message-latency: Public ordinary functions
rd-kafka-message-set-headers: Public ordinary functions
rd-kafka-message-status: Public ordinary functions
rd-kafka-message-timestamp: Public ordinary functions
rd-kafka-metadata: Public ordinary functions
rd-kafka-metadata-destroy: Public ordinary functions
rd-kafka-msg-partitioner-consistent: Public ordinary functions
rd-kafka-msg-partitioner-consistent-random: Public ordinary functions
rd-kafka-msg-partitioner-murmur2: Public ordinary functions
rd-kafka-msg-partitioner-murmur2-random: Public ordinary functions
rd-kafka-msg-partitioner-random: Public ordinary functions
rd-kafka-name: Public ordinary functions
rd-kafka-new: Public ordinary functions
rd-kafka-newpartitions-destroy: Public ordinary functions
rd-kafka-newpartitions-destroy-array: Public ordinary functions
rd-kafka-newpartitions-new: Public ordinary functions
rd-kafka-newpartitions-set-replica-assignment: Public ordinary functions
rd-kafka-newtopic-destroy: Public ordinary functions
rd-kafka-newtopic-destroy-array: Public ordinary functions
rd-kafka-newtopic-new: Public ordinary functions
rd-kafka-newtopic-set-config: Public ordinary functions
rd-kafka-newtopic-set-replica-assignment: Public ordinary functions
rd-kafka-offset-store: Public ordinary functions
rd-kafka-offsets-for-times: Public ordinary functions
rd-kafka-offsets-store: Public ordinary functions
rd-kafka-opaque: Public ordinary functions
rd-kafka-outq-len: Public ordinary functions
rd-kafka-pause-partitions: Public ordinary functions
rd-kafka-poll: Public ordinary functions
rd-kafka-poll-set-consumer: Public ordinary functions
rd-kafka-position: Public ordinary functions
rd-kafka-produce: Public ordinary functions
rd-kafka-produce-batch: Public ordinary functions
rd-kafka-producev: Public macros
rd-kafka-purge: Public ordinary functions
rd-kafka-query-watermark-offsets: Public ordinary functions
rd-kafka-queue-cb-event-enable: Public ordinary functions
rd-kafka-queue-destroy: Public ordinary functions
rd-kafka-queue-forward: Public ordinary functions
rd-kafka-queue-get-background: Public ordinary functions
rd-kafka-queue-get-consumer: Public ordinary functions
rd-kafka-queue-get-main: Public ordinary functions
rd-kafka-queue-get-partition: Public ordinary functions
rd-kafka-queue-io-event-enable: Public ordinary functions
rd-kafka-queue-length: Public ordinary functions
rd-kafka-queue-new: Public ordinary functions
rd-kafka-queue-poll: Public ordinary functions
rd-kafka-queue-poll-callback: Public ordinary functions
rd-kafka-resourcetype-name: Public ordinary functions
rd-kafka-resume-partitions: Public ordinary functions
rd-kafka-seek: Public ordinary functions
rd-kafka-send-offsets-to-transaction: Public ordinary functions
rd-kafka-set-log-level: Public ordinary functions
rd-kafka-set-log-queue: Public ordinary functions
rd-kafka-set-logger: Public ordinary functions
rd-kafka-subscribe: Public ordinary functions
rd-kafka-subscription: Public ordinary functions
rd-kafka-test-fatal-error: Public ordinary functions
rd-kafka-thread-cnt: Public ordinary functions
rd-kafka-topic-conf-destroy: Public ordinary functions
rd-kafka-topic-conf-dump: Public ordinary functions
rd-kafka-topic-conf-dup: Public ordinary functions
rd-kafka-topic-conf-get: Public ordinary functions
rd-kafka-topic-conf-new: Public ordinary functions
rd-kafka-topic-conf-set: Public ordinary functions
rd-kafka-topic-conf-set-msg-order-cmp: Public ordinary functions
rd-kafka-topic-conf-set-opaque: Public ordinary functions
rd-kafka-topic-conf-set-partitioner-cb: Public ordinary functions
rd-kafka-topic-destroy: Public ordinary functions
rd-kafka-topic-name: Public ordinary functions
rd-kafka-topic-new: Public ordinary functions
rd-kafka-topic-opaque: Public ordinary functions
rd-kafka-topic-partition-available: Public ordinary functions
rd-kafka-topic-partition-destroy: Public ordinary functions
rd-kafka-topic-partition-list-add: Public ordinary functions
rd-kafka-topic-partition-list-add-range: Public ordinary functions
rd-kafka-topic-partition-list-copy: Public ordinary functions
rd-kafka-topic-partition-list-del: Public ordinary functions
rd-kafka-topic-partition-list-del-by-idx: Public ordinary functions
rd-kafka-topic-partition-list-destroy: Public ordinary functions
rd-kafka-topic-partition-list-find: Public ordinary functions
rd-kafka-topic-partition-list-new: Public ordinary functions
rd-kafka-topic-partition-list-set-offset: Public ordinary functions
rd-kafka-topic-partition-list-sort: Public ordinary functions
rd-kafka-topic-result-error: Public ordinary functions
rd-kafka-topic-result-error-string: Public ordinary functions
rd-kafka-topic-result-name: Public ordinary functions
rd-kafka-type: Public ordinary functions
rd-kafka-unittest: Public ordinary functions
rd-kafka-unsubscribe: Public ordinary functions
rd-kafka-version: Public ordinary functions
rd-kafka-version-str: Public ordinary functions
rd-kafka-wait-destroyed: Public ordinary functions
rd-kafka-yield: Public ordinary functions
read-rd-kafka-queue-from-fd: Private ordinary functions
register-rd-kafka-queue: Private ordinary functions
resume: Public generic functions
resume: Public generic functions

S
seek: Public generic functions
seek: Public generic functions
seek-to-beginning: Public generic functions
seek-to-beginning: Public generic functions
seek-to-end: Public generic functions
seek-to-end: Public generic functions
send: Public generic functions
send: Public generic functions
send-offsets-to-transaction: Public generic functions
send-offsets-to-transaction: Public generic functions
send-offsets-to-transaction: Public generic functions
send-offsets-to-transaction: Public generic functions
serde-funcall: Private generic functions
serde-funcall: Private generic functions
serde-funcall: Private generic functions
set-conf: Private ordinary functions
set-keyvals: Private ordinary functions
set-rd-kafka-conf: Private ordinary functions
set-rd-kafka-topic-conf: Private ordinary functions
set-timeout: Private ordinary functions
set-validate: Private ordinary functions
subscribe: Public generic functions
subscribe: Public generic functions
subscribe: Public generic functions
subscription: Public generic functions
subscription: Public generic functions

T
then: Public generic functions
then: Public generic functions
timestamp: Public generic functions
timestamp: Public generic functions
topic: Public generic functions
topic: Public generic functions
topic: Public generic functions

U
unsubscribe: Public generic functions
unsubscribe: Public generic functions

V
value: Public generic functions
value: Public generic functions
value: Public generic functions

W
wait-for-fd: Private ordinary functions
watermarks: Public generic functions
watermarks: Public generic functions
with-conf: Private macros
with-consumer-group-metadata: Private macros
with-set-keyval: Private macros
with-toppar-list: Private macros

Jump to:   %  
A   B   C   D   E   F   G   H   I   K   M   N   O   P   R   S   T   U   V   W  

Next: , Previous: , Up: Indexes   [Contents][Index]

A.3 Variables

Jump to:   +  
B   C   D   E   F   G   H   K   L   N   O   P   R   S   T   V  
Index Entry  Section

+
+address->queue+: Private special variables
+address->queue-lock+: Private special variables
+errstr-len+: Private constants
+kernel+: Private special variables
+pointer-size+: Private special variables
+read-fd+: Private special variables
+write-fd+: Private special variables

B
baddies: Public conditions

C
client: Public classes
Constant, +errstr-len+: Private constants
Constant, rd-kafka-admin-op--cnt: Public constants
Constant, rd-kafka-admin-op-alterconfigs: Public constants
Constant, rd-kafka-admin-op-any: Public constants
Constant, rd-kafka-admin-op-createpartitions: Public constants
Constant, rd-kafka-admin-op-createtopics: Public constants
Constant, rd-kafka-admin-op-deletetopics: Public constants
Constant, rd-kafka-admin-op-describeconfigs: Public constants
Constant, rd-kafka-conf-invalid: Public constants
Constant, rd-kafka-conf-ok: Public constants
Constant, rd-kafka-conf-unknown: Public constants
Constant, rd-kafka-config-source--cnt: Public constants
Constant, rd-kafka-config-source-default-config: Public constants
Constant, rd-kafka-config-source-dynamic-broker-config: Public constants
Constant, rd-kafka-config-source-dynamic-default-broker-config: Public constants
Constant, rd-kafka-config-source-dynamic-topic-config: Public constants
Constant, rd-kafka-config-source-static-broker-config: Public constants
Constant, rd-kafka-config-source-unknown-config: Public constants
Constant, rd-kafka-consumer: Public constants
Constant, rd-kafka-msg-status-not-persisted: Public constants
Constant, rd-kafka-msg-status-persisted: Public constants
Constant, rd-kafka-msg-status-possibly-persisted: Public constants
Constant, rd-kafka-producer: Public constants
Constant, rd-kafka-resource--cnt: Public constants
Constant, rd-kafka-resource-any: Public constants
Constant, rd-kafka-resource-broker: Public constants
Constant, rd-kafka-resource-group: Public constants
Constant, rd-kafka-resource-topic: Public constants
Constant, rd-kafka-resource-unknown: Public constants
Constant, rd-kafka-resp-err--all-brokers-down: Public constants
Constant, rd-kafka-resp-err--application: Public constants
Constant, rd-kafka-resp-err--assign-partitions: Public constants
Constant, rd-kafka-resp-err--assignment-lost: Public constants
Constant, rd-kafka-resp-err--authentication: Public constants
Constant, rd-kafka-resp-err--bad-compression: Public constants
Constant, rd-kafka-resp-err--bad-msg: Public constants
Constant,