ContextToKafka returns an kafka RequestResponseFunc that injects an OpenTracing Span found in `ctx` into the http headers.

EncodeMarshaller encodes the user-domain request object into a *kafka.Message.

ErrHandler is a transport handler that logs the kafka error message at warning level.

KafkaToContext returns an http RequestFunc that tries to join with an OpenTracing trace found in `req` and starts a new Span called `operationName` accordingly.

MakeClient creates an Handler.

MakePublisherService returns a *PublisherService that can publish user-domain messages to kafka brokers.

MakeSubscriberServer creates a *SubscriberServer.

NewMux creates a SubscriberClientMux, which is a group of kafka servers.

NewPublisher constructs a usable Publisher for a single remote method.

NewSubscriber constructs a new subscriber, which provides a handler for Kafka messages.

PublisherAfter sets the ClientResponseFuncs applied to the incoming kafka request prior to it being decoded.

PublisherBefore sets the RequestFuncs that are applied to the outgoing kafka request before it's invoked.

PublisherTimeout sets the available timeout for an kafka request.

SubscriberAfter functions are executed on the subscriber reply after the endpoint is invoked, but before anything is published to the reply.

SubscriberBefore functions are executed on the publisher delivery object before the request is decoded.

SubscriberErrorHandler is used to handle non-terminal errors.

SubscriberErrorLogger is used to log non-terminal errors.

WithParallelism configures the parallelism of fan out workers.

WithSyncCommit is an kafka option that when enabled, only commit the message synchronously if no error is returned from the endpoint.

Publisher wraps a kafka client, and provides a method that implements endpoint.Endpoint.

PublisherService is a go kit service with one method, publish.

Subscriber is go kit transport layer that wraps an endpoint.

SubscriberClientMux is a group of kafka Server.

SubscriberServer is a kafka server that continuously consumes messages from kafka.

Handler is a symmetric interface for both kafka publication and subscription.

Reader models a kafka.Reader.

Server models a kafka server.

DecodeRequestFunc extracts a user-domain request object from a *kafka.Message.

DecodeResponseFunc extracts a user-domain response object from an *kafka.Message.

EncodeRequestFunc encodes the passed request object into a *kafka.Message.

EncodeResponseFunc encodes the passed response object to a *kafka.Message.

HandleFunc is a functional Handler.

A PublisherOpt is an option that configures publisher.

PublisherOption sets an optional parameter for clients.

ReaderOpt are options that configures the kafka reader.

RequestResponseFunc may take information from a publisher request and put it into a request context.

SubscriberOption sets an optional parameter for subscribers.