Emit sends a message over the Kafka interface.

SignedBlindedTokenIssuerHandler emits signed, blinded tokens based on provided blinded tokens.

StartConsumers reads configuration variables and starts the associated kafka consumers.

MessageContext is used for channel coordination when processing batches of messages.

TopicMapping represents a kafka topic, how to process it, and where to emit the result.

Processor is a function that is used to process Kafka messages on.