ConsumeLogChannel is supposed to be called in a goroutine.

LogProcessor consumes logs from a [LogEmitter] and passes them to an [slog.Logger].

DebugContextAdmin enables admin API debugging.

DebugContextAll enables all of the above.

DebugContextAssignor enables detailed consumer group partition assignor debugging.

DebugContextBroker enables broker and connection state debugging.

DebugContextConfig enables displaying set configuration properties on startup.

DebugContextConsumer enables high-level consumer debugging.

DebugContextConsumerGroup enables low-level consumer group state debugging.

DebugContextFeature enables Kafka protocol feature support as negotiated with the broker.

DebugContextFetch enables consumer message fetch debugging.

DebugContextGeneric enables generic client instance level debugging.

DebugContextIdempotentProducer enables idempotent Producer debugging.

DebugContextInterceptor enables interceptor interface debugging.

DebugContextMessage enables message debugging.

DebugContextMetadata enables cluster and topic metadata retrieval debugging.

DebugContextMock enables mock cluster functionality debugging.

DebugContextPlugin enables plugin loading debugging.

DebugContextProtocol enables Kafka protocol request/response debugging.

DebugContextQueue enables message queue debugging.

DebugContextSecurity enables security and authentication debugging.

DebugContextTopic enables topic and partition state debugging.

LogEmitter emits logs from a [kafka.Consumer] or [kafka.Producer].