The cl-rdkafka Reference Manual

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

• rd-kafka-abort-transaction (function).
• rd-kafka-admin-op--cnt (constant).
• rd-kafka-admin-op-alterconfigs (constant).
• rd-kafka-admin-op-any (constant).
• rd-kafka-admin-op-createpartitions (constant).
• rd-kafka-admin-op-createtopics (constant).
• rd-kafka-admin-op-deletetopics (constant).
• rd-kafka-admin-op-describeconfigs (constant).
• rd-kafka-adminoptions-destroy (function).
• rd-kafka-adminoptions-new (function).
• rd-kafka-adminoptions-set-broker (function).
• rd-kafka-adminoptions-set-opaque (function).
• rd-kafka-adminoptions-set-operation-timeout (function).
• rd-kafka-adminoptions-set-request-timeout (function).
• rd-kafka-adminoptions-set-validate-only (function).
• rd-kafka-alterconfigs (function).
• rd-kafka-alterconfigs-result-resources (function).
• rd-kafka-assign (function).
• rd-kafka-assignment (function).
• rd-kafka-begin-transaction (function).
• rd-kafka-brokers-add (function).
• rd-kafka-clusterid (function).
• rd-kafka-commit (function).
• rd-kafka-commit-message (function).
• rd-kafka-commit-queue (function).
• rd-kafka-commit-transaction (function).
• rd-kafka-committed (function).
• rd-kafka-conf (function).
• rd-kafka-conf-destroy (function).
• rd-kafka-conf-dump (function).
• rd-kafka-conf-dump-free (function).
• rd-kafka-conf-dup (function).
• rd-kafka-conf-dup-filter (function).
• rd-kafka-conf-get (function).
• rd-kafka-conf-interceptor-add-on-conf-destroy (function).
• rd-kafka-conf-interceptor-add-on-conf-dup (function).
• rd-kafka-conf-interceptor-add-on-conf-set (function).
• rd-kafka-conf-interceptor-add-on-new (function).
• rd-kafka-conf-invalid (constant).
• rd-kafka-conf-new (function).
• rd-kafka-conf-ok (constant).
• rd-kafka-conf-properties-show (function).
• rd-kafka-conf-set (function).
• rd-kafka-conf-set-background-event-cb (function).
• rd-kafka-conf-set-closesocket-cb (function).
• rd-kafka-conf-set-connect-cb (function).
• rd-kafka-conf-set-consume-cb (function).
• rd-kafka-conf-set-default-topic-conf (function).
• rd-kafka-conf-set-dr-cb (function).
• rd-kafka-conf-set-dr-msg-cb (function).
• rd-kafka-conf-set-error-cb (function).
• rd-kafka-conf-set-events (function).
• rd-kafka-conf-set-log-cb (function).
• rd-kafka-conf-set-offset-commit-cb (function).
• rd-kafka-conf-set-opaque (function).
• rd-kafka-conf-set-open-cb (function).
• rd-kafka-conf-set-rebalance-cb (function).
• rd-kafka-conf-set-socket-cb (function).
• rd-kafka-conf-set-stats-cb (function).
• rd-kafka-conf-set-throttle-cb (function).
• rd-kafka-conf-unknown (constant).
• rd-kafka-config-source--cnt (constant).
• rd-kafka-config-source-default-config (constant).
• rd-kafka-config-source-dynamic-broker-config (constant).
• rd-kafka-config-source-dynamic-default-broker-config (constant).
• rd-kafka-config-source-dynamic-topic-config (constant).
• rd-kafka-config-source-static-broker-config (constant).
• rd-kafka-config-source-unknown-config (constant).
• rd-kafka-configentry-is-default (function).
• rd-kafka-configentry-is-read-only (function).
• rd-kafka-configentry-is-sensitive (function).
• rd-kafka-configentry-is-synonym (function).
• rd-kafka-configentry-name (function).
• rd-kafka-configentry-source (function).
• rd-kafka-configentry-synonyms (function).
• rd-kafka-configentry-value (function).
• rd-kafka-configresource-configs (function).
• rd-kafka-configresource-destroy (function).
• rd-kafka-configresource-destroy-array (function).
• rd-kafka-configresource-error (function).
• rd-kafka-configresource-error-string (function).
• rd-kafka-configresource-name (function).
• rd-kafka-configresource-new (function).
• rd-kafka-configresource-set-config (function).
• rd-kafka-configresource-type (function).
• rd-kafka-configsource-name (function).
• rd-kafka-consume (function).
• rd-kafka-consume-batch (function).
• rd-kafka-consume-batch-queue (function).
• rd-kafka-consume-callback (function).
• rd-kafka-consume-callback-queue (function).
• rd-kafka-consume-queue (function).
• rd-kafka-consume-start (function).
• rd-kafka-consume-start-queue (function).
• rd-kafka-consume-stop (function).
• rd-kafka-consumer (constant).
• rd-kafka-consumer-close (function).
• rd-kafka-consumer-group-metadata (function).
• rd-kafka-consumer-group-metadata-destroy (function).
• rd-kafka-consumer-group-metadata-new (function).
• rd-kafka-consumer-group-metadata-read (function).
• rd-kafka-consumer-group-metadata-write (function).
• rd-kafka-consumer-poll (function).
• rd-kafka-controllerid (function).
• rd-kafka-createpartitions (function).
• rd-kafka-createpartitions-result-topics (function).
• rd-kafka-createtopics (function).
• rd-kafka-createtopics-result-topics (function).
• rd-kafka-default-topic-conf-dup (function).
• rd-kafka-deletetopic-destroy (function).
• rd-kafka-deletetopic-destroy-array (function).
• rd-kafka-deletetopic-new (function).
• rd-kafka-deletetopics (function).
• rd-kafka-deletetopics-result-topics (function).
• rd-kafka-describeconfigs (function).
• rd-kafka-describeconfigs-result-resources (function).
• rd-kafka-destroy (function).
• rd-kafka-destroy-flags (function).
• rd-kafka-dump (function).
• rd-kafka-err2name (function).
• rd-kafka-err2str (function).
• rd-kafka-errno (function).
• rd-kafka-errno2err (function).
• rd-kafka-error-code (function).
• rd-kafka-error-destroy (function).
• rd-kafka-error-is-fatal (function).
• rd-kafka-error-is-retriable (function).
• rd-kafka-error-name (function).
• rd-kafka-error-new (macro).
• rd-kafka-error-string (function).
• rd-kafka-error-txn-requires-abort (function).
• rd-kafka-event-alterconfigs-result (function).
• rd-kafka-event-createpartitions-result (function).
• rd-kafka-event-createtopics-result (function).
• rd-kafka-event-debug-contexts (function).
• rd-kafka-event-deletetopics-result (function).
• rd-kafka-event-describeconfigs-result (function).
• rd-kafka-event-destroy (function).
• rd-kafka-event-error (function).
• rd-kafka-event-error-is-fatal (function).
• rd-kafka-event-error-string (function).
• rd-kafka-event-log (function).
• rd-kafka-event-message-array (function).
• rd-kafka-event-message-count (function).
• rd-kafka-event-message-next (function).
• rd-kafka-event-name (function).
• rd-kafka-event-opaque (function).
• rd-kafka-event-stats (function).
• rd-kafka-event-topic-partition (function).
• rd-kafka-event-topic-partition-list (function).
• rd-kafka-event-type (function).
• rd-kafka-fatal-error (function).
• rd-kafka-flush (function).
• rd-kafka-get-debug-contexts (function).
• rd-kafka-get-err-descs (function).
• rd-kafka-get-watermark-offsets (function).
• rd-kafka-group-list-destroy (function).
• rd-kafka-header-add (function).
• rd-kafka-header-cnt (function).
• rd-kafka-header-get (function).
• rd-kafka-header-get-all (function).
• rd-kafka-header-get-last (function).
• rd-kafka-header-remove (function).
• rd-kafka-headers-copy (function).
• rd-kafka-headers-destroy (function).
• rd-kafka-headers-new (function).
• rd-kafka-init-transactions (function).
• rd-kafka-interceptor-add-on-acknowledgement (function).
• rd-kafka-interceptor-add-on-commit (function).
• rd-kafka-interceptor-add-on-consume (function).
• rd-kafka-interceptor-add-on-destroy (function).
• rd-kafka-interceptor-add-on-request-sent (function).
• rd-kafka-interceptor-add-on-send (function).
• rd-kafka-last-error (function).
• rd-kafka-list-groups (function).
• rd-kafka-log-print (function).
• rd-kafka-log-syslog (function).
• rd-kafka-mem-free (function).
• rd-kafka-memberid (function).
• rd-kafka-message-destroy (function).
• rd-kafka-message-detach-headers (function).
• rd-kafka-message-headers (function).
• rd-kafka-message-latency (function).
• rd-kafka-message-set-headers (function).
• rd-kafka-message-status (function).
• rd-kafka-message-timestamp (function).
• rd-kafka-metadata (function).
• rd-kafka-metadata-destroy (function).
• rd-kafka-msg-partitioner-consistent (function).
• rd-kafka-msg-partitioner-consistent-random (function).
• rd-kafka-msg-partitioner-murmur2 (function).
• rd-kafka-msg-partitioner-murmur2-random (function).
• rd-kafka-msg-partitioner-random (function).
• rd-kafka-msg-status-not-persisted (constant).
• rd-kafka-msg-status-persisted (constant).
• rd-kafka-msg-status-possibly-persisted (constant).
• rd-kafka-name (function).
• rd-kafka-new (function).
• rd-kafka-newpartitions-destroy (function).
• rd-kafka-newpartitions-destroy-array (function).
• rd-kafka-newpartitions-new (function).
• rd-kafka-newpartitions-set-replica-assignment (function).
• rd-kafka-newtopic-destroy (function).
• rd-kafka-newtopic-destroy-array (function).
• rd-kafka-newtopic-new (function).
• rd-kafka-newtopic-set-config (function).
• rd-kafka-newtopic-set-replica-assignment (function).
• rd-kafka-offset-store (function).
• rd-kafka-offsets-for-times (function).
• rd-kafka-offsets-store (function).
• rd-kafka-opaque (function).
• rd-kafka-outq-len (function).
• rd-kafka-pause-partitions (function).
• rd-kafka-poll (function).
• rd-kafka-poll-set-consumer (function).
• rd-kafka-position (function).
• rd-kafka-produce (function).
• rd-kafka-produce-batch (function).
• rd-kafka-producer (constant).
• rd-kafka-producev (macro).
• rd-kafka-purge (function).
• rd-kafka-query-watermark-offsets (function).
• rd-kafka-queue-cb-event-enable (function).
• rd-kafka-queue-destroy (function).
• rd-kafka-queue-forward (function).
• rd-kafka-queue-get-background (function).
• rd-kafka-queue-get-consumer (function).
• rd-kafka-queue-get-main (function).
• rd-kafka-queue-get-partition (function).
• rd-kafka-queue-io-event-enable (function).
• rd-kafka-queue-length (function).
• rd-kafka-queue-new (function).
• rd-kafka-queue-poll (function).
• rd-kafka-queue-poll-callback (function).
• rd-kafka-resource--cnt (constant).
• rd-kafka-resource-any (constant).
• rd-kafka-resource-broker (constant).
• rd-kafka-resource-group (constant).
• rd-kafka-resource-topic (constant).
• rd-kafka-resource-unknown (constant).
• rd-kafka-resourcetype-name (function).
• rd-kafka-resp-err--all-brokers-down (constant).
• rd-kafka-resp-err--application (constant).
• rd-kafka-resp-err--assign-partitions (constant).
• rd-kafka-resp-err--assignment-lost (constant).
• rd-kafka-resp-err--authentication (constant).
• rd-kafka-resp-err--bad-compression (constant).
• rd-kafka-resp-err--bad-msg (constant).
• rd-kafka-resp-err--begin (constant).
• rd-kafka-resp-err--conflict (constant).
• rd-kafka-resp-err--crit-sys-resource (constant).
• rd-kafka-resp-err--destroy (constant).
• rd-kafka-resp-err--end (constant).
• rd-kafka-resp-err--existing-subscription (constant).
• rd-kafka-resp-err--fail (constant).
• rd-kafka-resp-err--fatal (constant).
• rd-kafka-resp-err--fenced (constant).
• rd-kafka-resp-err--fs (constant).
• rd-kafka-resp-err--gapless-guarantee (constant).
• rd-kafka-resp-err--in-progress (constant).
• rd-kafka-resp-err--inconsistent (constant).
• rd-kafka-resp-err--intr (constant).
• rd-kafka-resp-err--invalid-arg (constant).
• rd-kafka-resp-err--invalid-type (constant).
• rd-kafka-resp-err--isr-insuff (constant).
• rd-kafka-resp-err--key-deserialization (constant).
• rd-kafka-resp-err--key-serialization (constant).
• rd-kafka-resp-err--max-poll-exceeded (constant).
• rd-kafka-resp-err--msg-timed-out (constant).
• rd-kafka-resp-err--no-offset (constant).
• rd-kafka-resp-err--node-update (constant).
• rd-kafka-resp-err--noent (constant).
• rd-kafka-resp-err--noop (constant).
• rd-kafka-resp-err--not-configured (constant).
• rd-kafka-resp-err--not-implemented (constant).
• rd-kafka-resp-err--outdated (constant).
• rd-kafka-resp-err--partial (constant).
• rd-kafka-resp-err--partition-eof (constant).
• rd-kafka-resp-err--prev-in-progress (constant).
• rd-kafka-resp-err--purge-inflight (constant).
• rd-kafka-resp-err--purge-queue (constant).
• rd-kafka-resp-err--queue-full (constant).
• rd-kafka-resp-err--read-only (constant).
• rd-kafka-resp-err--resolve (constant).
• rd-kafka-resp-err--retry (constant).
• rd-kafka-resp-err--revoke-partitions (constant).
• rd-kafka-resp-err--ssl (constant).
• rd-kafka-resp-err--state (constant).
• rd-kafka-resp-err--timed-out (constant).
• rd-kafka-resp-err--timed-out-queue (constant).
• rd-kafka-resp-err--transport (constant).
• rd-kafka-resp-err--underflow (constant).
• rd-kafka-resp-err--unknown-broker (constant).
• rd-kafka-resp-err--unknown-group (constant).
• rd-kafka-resp-err--unknown-partition (constant).
• rd-kafka-resp-err--unknown-protocol (constant).
• rd-kafka-resp-err--unknown-topic (constant).
• rd-kafka-resp-err--unsupported-feature (constant).
• rd-kafka-resp-err--value-deserialization (constant).
• rd-kafka-resp-err--value-serialization (constant).
• rd-kafka-resp-err--wait-cache (constant).
• rd-kafka-resp-err--wait-coord (constant).
• rd-kafka-resp-err-broker-not-available (constant).
• rd-kafka-resp-err-cluster-authorization-failed (constant).
• rd-kafka-resp-err-concurrent-transactions (constant).
• rd-kafka-resp-err-coordinator-load-in-progress (constant).
• rd-kafka-resp-err-coordinator-not-available (constant).
• rd-kafka-resp-err-delegation-token-auth-disabled (constant).
• rd-kafka-resp-err-delegation-token-authorization-failed (constant).
• rd-kafka-resp-err-delegation-token-expired (constant).
• rd-kafka-resp-err-delegation-token-not-found (constant).
• rd-kafka-resp-err-delegation-token-owner-mismatch (constant).
• rd-kafka-resp-err-delegation-token-request-not-allowed (constant).
• rd-kafka-resp-err-duplicate-resource (constant).
• rd-kafka-resp-err-duplicate-sequence-number (constant).
• rd-kafka-resp-err-election-not-needed (constant).
• rd-kafka-resp-err-eligible-leaders-not-available (constant).
• rd-kafka-resp-err-feature-update-failed (constant).
• rd-kafka-resp-err-fenced-instance-id (constant).
• rd-kafka-resp-err-fenced-leader-epoch (constant).
• rd-kafka-resp-err-fetch-session-id-not-found (constant).
• rd-kafka-resp-err-group-authorization-failed (constant).
• rd-kafka-resp-err-group-id-not-found (constant).
• rd-kafka-resp-err-group-max-size-reached (constant).
• rd-kafka-resp-err-group-subscribed-to-topic (constant).
• rd-kafka-resp-err-illegal-generation (constant).
• rd-kafka-resp-err-illegal-sasl-state (constant).
• rd-kafka-resp-err-inconsistent-group-protocol (constant).
• rd-kafka-resp-err-inconsistent-voter-set (constant).
• rd-kafka-resp-err-invalid-commit-offset-size (constant).
• rd-kafka-resp-err-invalid-config (constant).
• rd-kafka-resp-err-invalid-fetch-session-epoch (constant).
• rd-kafka-resp-err-invalid-group-id (constant).
• rd-kafka-resp-err-invalid-msg (constant).
• rd-kafka-resp-err-invalid-msg-size (constant).
• rd-kafka-resp-err-invalid-partitions (constant).
• rd-kafka-resp-err-invalid-principal-type (constant).
• rd-kafka-resp-err-invalid-producer-epoch (constant).
• rd-kafka-resp-err-invalid-producer-id-mapping (constant).
• rd-kafka-resp-err-invalid-record (constant).
• rd-kafka-resp-err-invalid-replica-assignment (constant).
• rd-kafka-resp-err-invalid-replication-factor (constant).
• rd-kafka-resp-err-invalid-request (constant).
• rd-kafka-resp-err-invalid-required-acks (constant).
• rd-kafka-resp-err-invalid-session-timeout (constant).
• rd-kafka-resp-err-invalid-timestamp (constant).
• rd-kafka-resp-err-invalid-transaction-timeout (constant).
• rd-kafka-resp-err-invalid-txn-state (constant).
• rd-kafka-resp-err-invalid-update-version (constant).
• rd-kafka-resp-err-kafka-storage-error (constant).
• rd-kafka-resp-err-leader-not-available (constant).
• rd-kafka-resp-err-listener-not-found (constant).
• rd-kafka-resp-err-log-dir-not-found (constant).
• rd-kafka-resp-err-member-id-required (constant).
• rd-kafka-resp-err-msg-size-too-large (constant).
• rd-kafka-resp-err-network-exception (constant).
• rd-kafka-resp-err-no-error (constant).
• rd-kafka-resp-err-no-reassignment-in-progress (constant).
• rd-kafka-resp-err-non-empty-group (constant).
• rd-kafka-resp-err-not-controller (constant).
• rd-kafka-resp-err-not-coordinator (constant).
• rd-kafka-resp-err-not-enough-replicas (constant).
• rd-kafka-resp-err-not-enough-replicas-after-append (constant).
• rd-kafka-resp-err-not-leader-for-partition (constant).
• rd-kafka-resp-err-offset-metadata-too-large (constant).
• rd-kafka-resp-err-offset-not-available (constant).
• rd-kafka-resp-err-offset-out-of-range (constant).
• rd-kafka-resp-err-operation-not-attempted (constant).
• rd-kafka-resp-err-out-of-order-sequence-number (constant).
• rd-kafka-resp-err-policy-violation (constant).
• rd-kafka-resp-err-preferred-leader-not-available (constant).
• rd-kafka-resp-err-principal-deserialization-failure (constant).
• rd-kafka-resp-err-producer-fenced (constant).
• rd-kafka-resp-err-reassignment-in-progress (constant).
• rd-kafka-resp-err-rebalance-in-progress (constant).
• rd-kafka-resp-err-record-list-too-large (constant).
• rd-kafka-resp-err-replica-not-available (constant).
• rd-kafka-resp-err-request-timed-out (constant).
• rd-kafka-resp-err-resource-not-found (constant).
• rd-kafka-resp-err-sasl-authentication-failed (constant).
• rd-kafka-resp-err-security-disabled (constant).
• rd-kafka-resp-err-stale-broker-epoch (constant).
• rd-kafka-resp-err-stale-ctrl-epoch (constant).
• rd-kafka-resp-err-throttling-quota-exceeded (constant).
• rd-kafka-resp-err-topic-already-exists (constant).
• rd-kafka-resp-err-topic-authorization-failed (constant).
• rd-kafka-resp-err-topic-deletion-disabled (constant).
• rd-kafka-resp-err-topic-exception (constant).
• rd-kafka-resp-err-transaction-coordinator-fenced (constant).
• rd-kafka-resp-err-transactional-id-authorization-failed (constant).
• rd-kafka-resp-err-unacceptable-credential (constant).
• rd-kafka-resp-err-unknown (constant).
• rd-kafka-resp-err-unknown-leader-epoch (constant).
• rd-kafka-resp-err-unknown-member-id (constant).
• rd-kafka-resp-err-unknown-producer-id (constant).
• rd-kafka-resp-err-unknown-topic-or-part (constant).
• rd-kafka-resp-err-unstable-offset-commit (constant).
• rd-kafka-resp-err-unsupported-compression-type (constant).
• rd-kafka-resp-err-unsupported-for-message-format (constant).
• rd-kafka-resp-err-unsupported-sasl-mechanism (constant).
• rd-kafka-resp-err-unsupported-version (constant).
• rd-kafka-resume-partitions (function).
• rd-kafka-seek (function).
• rd-kafka-send-offsets-to-transaction (function).
• rd-kafka-set-log-level (function).
• rd-kafka-set-log-queue (function).
• rd-kafka-set-logger (function).
• rd-kafka-subscribe (function).
• rd-kafka-subscription (function).
• rd-kafka-test-fatal-error (function).
• rd-kafka-thread-cnt (function).
• rd-kafka-timestamp-create-time (constant).
• rd-kafka-timestamp-log-append-time (constant).
• rd-kafka-timestamp-not-available (constant).
• rd-kafka-topic-conf-destroy (function).
• rd-kafka-topic-conf-dump (function).
• rd-kafka-topic-conf-dup (function).
• rd-kafka-topic-conf-get (function).
• rd-kafka-topic-conf-new (function).
• rd-kafka-topic-conf-set (function).
• rd-kafka-topic-conf-set-msg-order-cmp (function).
• rd-kafka-topic-conf-set-opaque (function).
• rd-kafka-topic-conf-set-partitioner-cb (function).
• rd-kafka-topic-destroy (function).
• rd-kafka-topic-name (function).
• rd-kafka-topic-new (function).
• rd-kafka-topic-opaque (function).
• rd-kafka-topic-partition-available (function).
• rd-kafka-topic-partition-destroy (function).
• rd-kafka-topic-partition-list-add (function).
• rd-kafka-topic-partition-list-add-range (function).
• rd-kafka-topic-partition-list-copy (function).
• rd-kafka-topic-partition-list-del (function).
• rd-kafka-topic-partition-list-del-by-idx (function).
• rd-kafka-topic-partition-list-destroy (function).
• rd-kafka-topic-partition-list-find (function).
• rd-kafka-topic-partition-list-new (function).
• rd-kafka-topic-partition-list-set-offset (function).
• rd-kafka-topic-partition-list-sort (function).
• rd-kafka-topic-result-error (function).
• rd-kafka-topic-result-error-string (function).
• rd-kafka-topic-result-name (function).
• rd-kafka-type (function).
• rd-kafka-unittest (function).
• rd-kafka-unsubscribe (function).
• rd-kafka-version (function).
• rd-kafka-version-str (function).
• rd-kafka-vtype-end (constant).
• rd-kafka-vtype-header (constant).
• rd-kafka-vtype-headers (constant).
• rd-kafka-vtype-key (constant).
• rd-kafka-vtype-msgflags (constant).
• rd-kafka-vtype-opaque (constant).
• rd-kafka-vtype-partition (constant).
• rd-kafka-vtype-rkt (constant).
• rd-kafka-vtype-timestamp (constant).
• rd-kafka-vtype-topic (constant).
• rd-kafka-vtype-value (constant).
• rd-kafka-wait-destroyed (function).
• rd-kafka-yield (function).

Internals

• defcenum (macro).
• defcfun (macro).
• defcstruct (macro).
• defctype (macro).
• get-name (function).
• rd-kafka-err-desc-tclass (class).
• rd-kafka-group-info-tclass (class).
• rd-kafka-group-list-tclass (class).
• rd-kafka-group-member-info-tclass (class).
• rd-kafka-message-tclass (class).
• rd-kafka-metadata-broker-tclass (class).
• rd-kafka-metadata-partition-tclass (class).
• rd-kafka-metadata-tclass (class).
• rd-kafka-metadata-topic-tclass (class).
• rd-kafka-topic-partition-list-tclass (class).
• rd-kafka-topic-partition-tclass (class).

---

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

• +errstr-len+ (constant).
• byte-seq (type).
• byte-seq-p (function).
• bytes->pointer (function).
• pointer->bytes (function).

---

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

Dependency

package.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Public Interface

• abort-required-error (condition).
• allocation-error (condition).
• baddies (reader method).
• description (reader method).
• description (reader method).
• enum (reader method).
• fatal-error (condition).
• goodies (reader method).
• kafka-error (condition).
• name (reader method).
• partial-error (condition).
• partition (reader method).
• partition-error (condition).
• rdkafka-error (condition).
• retryable-operation-error (condition).
• topic (reader method).
• transaction-error (condition).

Internals

• error->condition (function).
• make-partition-error (function).
• make-rdkafka-error (function).

---

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

Dependency

common.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Internals

• alloc-rd-kafka-conf (function).
• alloc-rd-kafka-topic-conf (function).
• make-conf (generic function).
• make-conf-from-alist (function).
• make-conf-from-plist (function).
• make-set-keyval (macro).
• set-rd-kafka-conf (function).
• set-rd-kafka-topic-conf (function).
• with-conf (macro).
• with-set-keyval (macro).

---

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

Dependency

common.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Internals

• apply-serde (generic function).
• deserializer (class).
• serde (class).
• serde-funcall (generic function).
• serializer (class).

---

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

Dependencies

• common.lisp (file).
• conditions.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Public Interface

• headers (reader method).
• key (generic function).
• message (class).
• offset (reader method).
• partition (reader method).
• timestamp (generic function).
• topic (reader method).
• value (generic function).

Internals

• get-headers (function).
• get-key (function).
• get-latency (function).
• get-payload (function).
• get-timestamp (function).
• get-topic (function).
• headers->alist (function).
• parse-timestamp-type (function).
• rd-kafka-message->message (function).

---

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

• pollfd-tclass (class).
• posix-close (function).
• posix-pipe (function).
• posix-poll (function).
• posix-read (function).
• posix-write (function).

---

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

• +address->queue+ (special variable).
• +address->queue-lock+ (special variable).
• +kernel+ (special variable).
• +pointer-size+ (special variable).
• +read-fd+ (special variable).
• +write-fd+ (special variable).
• assert-expected-event (function).
• assert-good-revents (function).
• deregister-rd-kafka-queue (function).
• enable-event-io (function).
• enqueue-payload (function).
• init-fds (function).
• init-kernel (function).
• poll-loop (function).
• process-events (function).
• read-rd-kafka-queue-from-fd (function).
• register-rd-kafka-queue (function).
• wait-for-fd (function).

---

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

Dependency

event-io (module).

Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Public Interface

• donep (generic function).
• future (class).
• then (generic function).
• value (method).

---

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

Dependencies

• common.lisp (file).
• conditions.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Internals

• add-toppar (function).
• alloc-toppar-list (function).
• alloc-toppar-list-from-alist (function).
• foreach-toppar (macro).
• with-toppar-list (macro).

---

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

Dependencies

• conf.lisp (file).
• conditions.lisp (file).
• serde.lisp (file).
• message.lisp (file).
• event-io (module).
• future.lisp (file).
• toppar.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Public Interface

• assign (generic function).
• assignment (generic function).
• close (generic function).
• commit (generic function).
• committed (generic function).
• consumer (class).
• initialize-instance (method).
• member-id (generic function).
• offsets-for-times (generic function).
• pause (generic function).
• poll (generic function).
• positions (generic function).
• resume (generic function).
• seek (generic function).
• seek-to-beginning (generic function).
• seek-to-end (generic function).
• subscribe (generic function).
• subscription (generic function).
• unsubscribe (generic function).
• watermarks (generic function).

Internals

• %assignment (function).
• %commit (function).
• %seek (function).
• %subscription (function).
• get-good-commits-and-assert-no-bad-commits (function).
• make-consumer-finalizer (function).
• process-commit-event (function).

---

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

Dependency

consumer.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

high-level (module).

Public Interface

• abort-transaction (generic function).
• begin-transaction (generic function).
• commit-transaction (generic function).
• flush (generic function).
• initialize-instance (method).
• initialize-transactions (generic function).
• producer (class).
• send (generic function).
• send-offsets-to-transaction (generic function).

Internals

• %send (function).
• %send-offsets-to-transaction (function).
• add-header (function).
• make-headers (function).
• make-producer-finalizer (function).
• messages->toppar-list (function).
• process-send-event (function).
• with-consumer-group-metadata (macro).

---

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

Source

cl-rdkafka.asd.

Parent Component

admin (module).

Internals

• assert-successful-event (macro).
• config-op-p (function).
• def-admin-methods (macro).
• event->result (macro).
• find-field-function (macro).
• find-function (macro).
• find-result-function (macro).
• get-config-data (function).
• get-synonyms (function).
• make-admin-options (function).
• make-loop (macro).
• make-rd-kafka-queue (function).
• parse-configentry (function).
• perform-admin-op (macro).
• set-timeout (function).
• set-validate (function).

---

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

Dependency

common.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

admin (module).

Internals

• %create-topic (function).
• create-topic (generic function).
• make-newtopic (function).
• set-conf (function).

---

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

Dependency

common.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

admin (module).

Internals

• %delete-topic (function).
• delete-topic (generic function).
• make-deletetopic (function).

---

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

Dependency

common.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

admin (module).

Internals

• %create-partitions (function).
• create-partitions (generic function).
• make-newpart (function).

---

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

Dependency

common.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

admin (module).

Internals

• %alter-config (function).
• %describe-config (function).
• alter-config (generic function).
• describe-config (generic function).
• get-conf (generic function).
• giant-alist->decent-alist (function).
• make-configresource (function).
• set-keyvals (function).

---

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

Dependency

common.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

admin (module).

Internals

• %cluster-metadata (function).
• cluster-id (generic function).
• cluster-metadata (generic function).
• controller-id (generic function).
• make-topic (function).
• parse-broker-metadata (function).
• parse-cluster-metadata (function).
• parse-partitions-metadata (function).
• parse-topic-metadata (function).

---

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

Dependency

common.lisp (file).

Source

cl-rdkafka.asd.

Parent Component

admin (module).

Internals

• %group-info (function).
• group-info (generic function).
• parse-broker-group-info (function).
• parse-group-info (function).
• parse-group-list (function).
• parse-member-info (function).
• parse-members-group-info (function).

---

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.

---