NewProduceRequestHandler creates a new request key handler for the Produce Request.

NewProxy creates a new Kafka Proxy based on a given configuration.

NewProxyConfig creates a new ProxyConfig.

WithDebug enables/disables debug.

WithDialAddressMapping configures Dial Address Mapping.

WithExtra configures extra parameters.

WithMessageHandler configures a handler that will handle all incoming messages.

WithMessagePublisher configures a publisher where the messages will be published after being handled.

WithMessageSubscriber configures a subscriber subscribed to the messages published by the configured c.MessagePublisher.

RequestAPIKeyProduce is the Kafka request API Key for the Produce Request.

ProxyConfig holds the configuration for the Kafka Proxy.

TLSConfig holds configuration for TLS.

ProxyOption represents a functional configuration for the Proxy.