f
createKafka

Creates a Kafka event log connector for production use.

c
EventLog

Event log wrapper with Task/Stream semantics for event-sourced systems.

c
EventLogKafkaAppendFailed

Error thrown when an append operation fails.

c
EventLogKafkaCloseFailed

Error thrown when closing an event log connection fails.

c
EventLogKafkaCommitCursorFailed

Error thrown when committing a cursor fails.

c
EventLogKafkaConnectionFailed

Error thrown when a Kafka event log connection cannot be established.

c
EventLogKafkaConsumeFailed

Error thrown when consuming events fails.

c
EventLogKafkaGetCursorFailed

Error thrown when getting a cursor fails.

c
EventLogKafkaGetFailed

Error thrown when getting an event fails.

c
EventLogKafkaListFailed

Error thrown when listing events fails.

I
KafkaConnector
No documentation available
I
KafkaCursor

Cursor type for Kafka, tracking position across partitions.

I
KafkaOptions

Configuration options for Kafka event log connector.