This is the cl-rdkafka Reference Manual, version 1.2.1, generated automatically by Declt version 4.0 beta 2 "William Riker" on Sun Sep 15 04:23:15 2024 GMT+0.
cl-rdkafka/cl-rdkafka.asd
cl-rdkafka/low-level/package.lisp
cl-rdkafka/low-level/librdkafka-grovel.lisp
cl-rdkafka/low-level/librdkafka-bindings.lisp
cl-rdkafka/high-level/package.lisp
cl-rdkafka/high-level/common.lisp
cl-rdkafka/high-level/conditions.lisp
cl-rdkafka/high-level/conf.lisp
cl-rdkafka/high-level/serde.lisp
cl-rdkafka/high-level/message.lisp
cl-rdkafka/high-level/event-io/posix-grovel.lisp
cl-rdkafka/high-level/event-io/posix.lisp
cl-rdkafka/high-level/event-io/kernel.lisp
cl-rdkafka/high-level/future.lisp
cl-rdkafka/high-level/toppar.lisp
cl-rdkafka/high-level/consumer.lisp
cl-rdkafka/high-level/producer.lisp
cl-rdkafka/high-level/admin/common.lisp
cl-rdkafka/high-level/admin/create-topic.lisp
cl-rdkafka/high-level/admin/delete-topic.lisp
cl-rdkafka/high-level/admin/create-partitions.lisp
cl-rdkafka/high-level/admin/config.lisp
cl-rdkafka/high-level/admin/cluster-metadata.lisp
cl-rdkafka/high-level/admin/group-info.lisp
The main system appears first, followed by any subsystem dependency.
cl-rdkafka
A client library for Apache Kafka based on librdkafka CFFI bindings.
Sahil Kang <sahil.kang@asilaycomputing.com>
GPLv3
1.2.1
cffi-grovel
(system).
cffi
(system).
trivial-garbage
(system).
bordeaux-threads
(system).
lparallel
(system).
low-level
(module).
high-level
(module).
Modules are listed depth-first from the system components tree.
cl-rdkafka/low-level
cl-rdkafka/high-level
cl-rdkafka/high-level/event-io
cl-rdkafka/high-level/admin
cl-rdkafka/low-level
cl-rdkafka
(system).
package.lisp
(file).
librdkafka-grovel.lisp
(file).
librdkafka-bindings.lisp
(file).
cl-rdkafka/high-level
low-level
(module).
cl-rdkafka
(system).
package.lisp
(file).
common.lisp
(file).
conditions.lisp
(file).
conf.lisp
(file).
serde.lisp
(file).
message.lisp
(file).
event-io
(module).
future.lisp
(file).
toppar.lisp
(file).
consumer.lisp
(file).
producer.lisp
(file).
admin
(module).
cl-rdkafka/high-level/event-io
package.lisp
(file).
conditions.lisp
(file).
high-level
(module).
posix-grovel.lisp
(file).
posix.lisp
(file).
kernel.lisp
(file).
cl-rdkafka/high-level/admin
consumer.lisp
(file).
producer.lisp
(file).
high-level
(module).
common.lisp
(file).
create-topic.lisp
(file).
delete-topic.lisp
(file).
create-partitions.lisp
(file).
config.lisp
(file).
cluster-metadata.lisp
(file).
group-info.lisp
(file).
Files are sorted by type and then listed depth-first from the systems components trees.
cl-rdkafka/cl-rdkafka.asd
cl-rdkafka/low-level/package.lisp
cl-rdkafka/low-level/librdkafka-grovel.lisp
cl-rdkafka/low-level/librdkafka-bindings.lisp
cl-rdkafka/high-level/package.lisp
cl-rdkafka/high-level/common.lisp
cl-rdkafka/high-level/conditions.lisp
cl-rdkafka/high-level/conf.lisp
cl-rdkafka/high-level/serde.lisp
cl-rdkafka/high-level/message.lisp
cl-rdkafka/high-level/event-io/posix-grovel.lisp
cl-rdkafka/high-level/event-io/posix.lisp
cl-rdkafka/high-level/event-io/kernel.lisp
cl-rdkafka/high-level/future.lisp
cl-rdkafka/high-level/toppar.lisp
cl-rdkafka/high-level/consumer.lisp
cl-rdkafka/high-level/producer.lisp
cl-rdkafka/high-level/admin/common.lisp
cl-rdkafka/high-level/admin/create-topic.lisp
cl-rdkafka/high-level/admin/delete-topic.lisp
cl-rdkafka/high-level/admin/create-partitions.lisp
cl-rdkafka/high-level/admin/config.lisp
cl-rdkafka/high-level/admin/cluster-metadata.lisp
cl-rdkafka/high-level/admin/group-info.lisp
cl-rdkafka/low-level/librdkafka-grovel.lisp
package.lisp
(file).
low-level
(module).
cl-rdkafka/low-level/librdkafka-bindings.lisp
librdkafka-grovel.lisp
(file).
low-level
(module).
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).
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).
cl-rdkafka/high-level/common.lisp
package.lisp
(file).
high-level
(module).
+errstr-len+
(constant).
byte-seq
(type).
byte-seq-p
(function).
bytes->pointer
(function).
pointer->bytes
(function).
cl-rdkafka/high-level/conditions.lisp
package.lisp
(file).
high-level
(module).
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).
error->condition
(function).
make-partition-error
(function).
make-rdkafka-error
(function).
cl-rdkafka/high-level/conf.lisp
common.lisp
(file).
high-level
(module).
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).
cl-rdkafka/high-level/serde.lisp
common.lisp
(file).
high-level
(module).
apply-serde
(generic function).
deserializer
(class).
serde
(class).
serde-funcall
(generic function).
serializer
(class).
cl-rdkafka/high-level/message.lisp
common.lisp
(file).
conditions.lisp
(file).
high-level
(module).
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).
cl-rdkafka/high-level/event-io/posix.lisp
posix-grovel.lisp
(file).
event-io
(module).
pollfd-tclass
(class).
posix-close
(function).
posix-pipe
(function).
posix-poll
(function).
posix-read
(function).
posix-write
(function).
cl-rdkafka/high-level/event-io/kernel.lisp
posix.lisp
(file).
event-io
(module).
+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).
cl-rdkafka/high-level/future.lisp
event-io
(module).
high-level
(module).
cl-rdkafka/high-level/toppar.lisp
common.lisp
(file).
conditions.lisp
(file).
high-level
(module).
add-toppar
(function).
alloc-toppar-list
(function).
alloc-toppar-list-from-alist
(function).
foreach-toppar
(macro).
with-toppar-list
(macro).
cl-rdkafka/high-level/consumer.lisp
conf.lisp
(file).
conditions.lisp
(file).
serde.lisp
(file).
message.lisp
(file).
event-io
(module).
future.lisp
(file).
toppar.lisp
(file).
high-level
(module).
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).
%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).
cl-rdkafka/high-level/producer.lisp
consumer.lisp
(file).
high-level
(module).
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).
%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).
cl-rdkafka/high-level/admin/common.lisp
admin
(module).
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).
cl-rdkafka/high-level/admin/create-topic.lisp
common.lisp
(file).
admin
(module).
%create-topic
(function).
create-topic
(generic function).
make-newtopic
(function).
set-conf
(function).
cl-rdkafka/high-level/admin/delete-topic.lisp
common.lisp
(file).
admin
(module).
%delete-topic
(function).
delete-topic
(generic function).
make-deletetopic
(function).
cl-rdkafka/high-level/admin/create-partitions.lisp
common.lisp
(file).
admin
(module).
%create-partitions
(function).
create-partitions
(generic function).
make-newpart
(function).
cl-rdkafka/high-level/admin/config.lisp
common.lisp
(file).
admin
(module).
%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).
cl-rdkafka/high-level/admin/cluster-metadata.lisp
common.lisp
(file).
admin
(module).
%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).
cl-rdkafka/high-level/admin/group-info.lisp
common.lisp
(file).
admin
(module).
%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).
Packages are listed by definition order.
cl-rdkafka/low-level
cl-rdkafka/ll
common-lisp
.
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).
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).
cl-rdkafka
kf
common-lisp
.
abort-required-error
(condition).
abort-transaction
(generic function).
allocation-error
(condition).
assign
(generic function).
assignment
(generic function).
baddies
(generic reader).
begin-transaction
(generic function).
close
(generic function).
commit
(generic function).
commit-transaction
(generic function).
committed
(generic function).
consumer
(class).
description
(generic reader).
donep
(generic function).
enum
(generic reader).
fatal-error
(condition).
flush
(generic function).
future
(class).
goodies
(generic reader).
headers
(generic reader).
initialize-transactions
(generic function).
kafka-error
(condition).
key
(generic function).
member-id
(generic function).
message
(class).
name
(generic reader).
offset
(generic reader).
offsets-for-times
(generic function).
partial-error
(condition).
partition
(generic reader).
partition-error
(condition).
pause
(generic function).
poll
(generic function).
positions
(generic function).
producer
(class).
rdkafka-error
(condition).
resume
(generic function).
retryable-operation-error
(condition).
seek
(generic function).
seek-to-beginning
(generic function).
seek-to-end
(generic function).
send
(generic function).
send-offsets-to-transaction
(generic function).
subscribe
(generic function).
subscription
(generic function).
then
(generic function).
timestamp
(generic function).
topic
(generic reader).
transaction-error
(condition).
unsubscribe
(generic function).
value
(generic function).
watermarks
(generic function).
%alter-config
(function).
%assignment
(function).
%cluster-metadata
(function).
%commit
(function).
%create-partitions
(function).
%create-topic
(function).
%delete-topic
(function).
%describe-config
(function).
%group-info
(function).
%seek
(function).
%send
(function).
%send-offsets-to-transaction
(function).
%subscription
(function).
+address->queue+
(special variable).
+address->queue-lock+
(special variable).
+errstr-len+
(constant).
+kernel+
(special variable).
+pointer-size+
(special variable).
+read-fd+
(special variable).
+write-fd+
(special variable).
add-header
(function).
add-toppar
(function).
alloc-rd-kafka-conf
(function).
alloc-rd-kafka-topic-conf
(function).
alloc-toppar-list
(function).
alloc-toppar-list-from-alist
(function).
alter-config
(generic function).
apply-serde
(generic function).
assert-expected-event
(function).
assert-good-revents
(function).
assert-successful-event
(macro).
byte-seq
(type).
byte-seq-p
(function).
bytes->pointer
(function).
cluster-id
(generic function).
cluster-metadata
(generic function).
config-op-p
(function).
controller-id
(generic function).
create-partitions
(generic function).
create-topic
(generic function).
def-admin-methods
(macro).
delete-topic
(generic function).
deregister-rd-kafka-queue
(function).
describe-config
(generic function).
deserializer
(class).
enable-event-io
(function).
enqueue-payload
(function).
error->condition
(function).
event->result
(macro).
find-field-function
(macro).
find-function
(macro).
find-result-function
(macro).
foreach-toppar
(macro).
get-conf
(generic function).
get-config-data
(function).
get-good-commits-and-assert-no-bad-commits
(function).
get-headers
(function).
get-key
(function).
get-latency
(function).
get-payload
(function).
get-synonyms
(function).
get-timestamp
(function).
get-topic
(function).
giant-alist->decent-alist
(function).
group-info
(generic function).
headers->alist
(function).
init-fds
(function).
init-kernel
(function).
make-admin-options
(function).
make-conf
(generic function).
make-conf-from-alist
(function).
make-conf-from-plist
(function).
make-configresource
(function).
make-consumer-finalizer
(function).
make-deletetopic
(function).
make-headers
(function).
make-loop
(macro).
make-newpart
(function).
make-newtopic
(function).
make-partition-error
(function).
make-producer-finalizer
(function).
make-rd-kafka-queue
(function).
make-rdkafka-error
(function).
make-set-keyval
(macro).
make-topic
(function).
messages->toppar-list
(function).
parse-broker-group-info
(function).
parse-broker-metadata
(function).
parse-cluster-metadata
(function).
parse-configentry
(function).
parse-group-info
(function).
parse-group-list
(function).
parse-member-info
(function).
parse-members-group-info
(function).
parse-partitions-metadata
(function).
parse-timestamp-type
(function).
parse-topic-metadata
(function).
perform-admin-op
(macro).
pointer->bytes
(function).
poll-loop
(function).
pollfd-tclass
(class).
posix-close
(function).
posix-pipe
(function).
posix-poll
(function).
posix-read
(function).
posix-write
(function).
process-commit-event
(function).
process-events
(function).
process-send-event
(function).
rd-kafka-message->message
(function).
read-rd-kafka-queue-from-fd
(function).
register-rd-kafka-queue
(function).
serde
(class).
serde-funcall
(generic function).
serializer
(class).
set-conf
(function).
set-keyvals
(function).
set-rd-kafka-conf
(function).
set-rd-kafka-topic-conf
(function).
set-timeout
(function).
set-validate
(function).
wait-for-fd
(function).
with-conf
(macro).
with-consumer-group-metadata
(macro).
with-set-keyval
(macro).
with-toppar-list
(macro).
Definitions are sorted by export status, category, package, and then by lexicographic order.
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.
partial-error
)) ¶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.
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.
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
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
allocation-error
)) ¶kafka-error
)) ¶rdkafka-error
)) ¶enum
.
partial-error
)) ¶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.
allocation-error
)) ¶name
.
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
message
)) ¶The partition this message originated from.
partition-error
)) ¶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
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
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
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.
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
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.
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.
message
)) ¶The topic this message originated from.
partition-error
)) ¶producer
) &key conf serde key-serde value-serde) ¶consumer
) &key conf serde key-serde value-serde) ¶Condition signalled when a transaction fails and must be aborted.
Condition signalled when librdkafka functions fail to allocate pointers.
storage-condition
.
Name of the object that failed to be allocated.
(quote (error "must supply name"))
:name
name
.
This slot is read-only.
Details about why the allocation may have failed.
(quote nil)
:description
This slot is read-only.
Condition signalled for librdkafka fatal errors.
These conditions indicate that the PRODUCER or CONSUMER instance should no longer be used.
Generic condition signalled by cl-rdkafka for expected errors.
error
.
Hopefully some descriptive description describing the error.
(quote (error "must supply description"))
:description
This slot is read-only.
Condition signalled for operations that partially failed.
Successful results.
(quote (error "must supply goodies"))
:goodies
This slot is read-only.
Condition signalled for errors specific to a topic’s partition.
Topic name.
(quote (error "must supply topic"))
:topic
This slot is read-only.
Condition signalled for librdkafka errors.
enum
.
Condition signalled by retryable operations that fail during transactions.
Condition signalled for errors related to transactions.
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)))
alter-config
.
assign
.
assignment
.
close
.
cluster-id
.
cluster-metadata
.
cluster-metadata
.
cluster-metadata
.
commit
.
committed
.
controller-id
.
create-partitions
.
create-topic
.
delete-topic
.
describe-config
.
describe-config
.
get-conf
.
group-info
.
group-info
.
initialize-instance
.
member-id
.
offsets-for-times
.
pause
.
poll
.
positions
.
resume
.
seek
.
seek-to-beginning
.
seek-to-end
.
send-offsets-to-transaction
.
send-offsets-to-transaction
.
send-offsets-to-transaction
.
subscribe
.
subscribe
.
subscription
.
unsubscribe
.
watermarks
.
Pointer to rd_kafka_t struct.
Pointer to rd_kafka_queue_t struct.
DESERIALIZER to map byte vector to object.
cl-rdkafka::deserializer
DESERIALIZER to map byte vector to object.
cl-rdkafka::deserializer
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"
lparallel promise that backs this future object.
(error "must supply lparallel promise")
:promise
Reference to a producer/consumer to prevent gc during promise fulfillment.
(or cl-rdkafka:consumer cl-rdkafka:producer)
(error "must supply producer or consumer")
:client
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)))
)
Message’s serialized key as a byte vector.
(and vector cl-rdkafka::byte-seq)
:raw-key
Message’s serialized value as a byte vector.
(and vector cl-rdkafka::byte-seq)
:raw-value
Message’s deserialized key.
:key
Message’s deserialized value.
:value
The topic this message originated from.
string
:topic
This slot is read-only.
The partition this message originated from.
integer
:partition
This slot is read-only.
Message offset.
integer
:offset
This slot is read-only.
Message timestamp measured in milliseconds since the UTC epoch, or nil.
(or null integer)
:timestamp
Type of message timestamp, or nil.
(member nil :create-time :log-append-time)
:timestamp-type
Message latency measured in microseconds from the send call, or nil.
(or null integer)
:latency
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))
abort-transaction
.
alter-config
.
begin-transaction
.
cluster-id
.
cluster-metadata
.
cluster-metadata
.
cluster-metadata
.
commit-transaction
.
controller-id
.
create-partitions
.
create-topic
.
delete-topic
.
describe-config
.
describe-config
.
flush
.
get-conf
.
group-info
.
group-info
.
initialize-instance
.
initialize-transactions
.
send
.
send-offsets-to-transaction
.
send-offsets-to-transaction
.
send-offsets-to-transaction
.
Pointer to rd_kafka_t struct.
Pointer to rd_kafka_queue_t struct.
Latest promise from send call.
SERIALIZER to map object to byte sequence.
cl-rdkafka::serializer
SERIALIZER to map object to byte sequence.
cl-rdkafka::serializer
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.
Maps an rd_kafka_queue_t pointer address to (function . queue).
C pointer size in bytes.
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.
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.
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.
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.
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.
Convenience wrapper for ALLOC-TOPPAR-LIST.
The elements of SEQ should look like either: * ((topic . partition) . (offset . metadata)) * ((topic . partition) . offset)
Allocates and returns a new uint8 pointer to BYTES.
Return a list of (:id :host :port) alists.
Returns a (:originating-broker :broker-metadata :topic-metadata) alist.
Return a list of (:id :leader :replicas :in-sync-replicas) alists.
Return a list of (:topic :partitions) alists.
Copies cffi :pointer bytes into a byte vector.
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.
Alter config of TOPIC according to CONFIG, reverting to defaults for unspecified configs.
Returns the cluster-id as reported in the broker metadata.
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)))))))))
Returns the controller-id as reported in the broker metadata, or nil.
Increase TOPIC’s partition count up to PARTITIONS and return PARTITIONS on success.
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.
Delete topic TOPIC and return TOPIC on success.
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.
Return an alist describing the client config of CLIENT.
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)))))
deserializer
) arg) ¶serializer
) arg) ¶foreign-struct-type
.
translatable-foreign-type
.
foreign-struct-type
.
translatable-foreign-type
.
foreign-struct-type
.
translatable-foreign-type
.
foreign-struct-type
.
translatable-foreign-type
.
foreign-struct-type
.
translatable-foreign-type
.
foreign-struct-type
.
translatable-foreign-type
.
foreign-struct-type
.
translatable-foreign-type
.
foreign-struct-type
.
translatable-foreign-type
.
foreign-struct-type
.
translatable-foreign-type
.
foreign-struct-type
.
translatable-foreign-type
.
foreign-struct-type
.
translatable-foreign-type
.
foreign-struct-type
.
translatable-foreign-type
.
Jump to: | %
A B C D E F G H I K M N O P R S T U V W |
---|
Jump to: | %
A B C D E F G H I K M N O P R S T U V W |
---|
Jump to: | +
B C D E F G H K L N O P R S T V |
---|
Jump to: | +
B C D E F G H K L N O P R S T V |
---|
Jump to: | A B C D E F G H K L M P R S T |
---|
Jump to: | A B C D E F G H K L M P R S T |
---|