AsyncDeliverer delivers the supplied message and returns a nil response.

AsyncDelivererCtx delivers the supplied message and returns a nil response.

DefaultErrorEncoder simply ignores the message.

EncodeJSONRequest is an EncodeRequestFunc that serializes the request as a JSON object to the Message value.

NewInstrumentedSubscriber constructs a new subscriber provides a handler for kafka messages.

NewPublisher constructs a new publisher for a single Kafka topic, which implements endpoint.Endpoint.

NewSubscriber constructs a new subscriber provides a handler for kafka messages.

PublisherAfter adds one or more PublisherResponseFuncs, which are applied to the context after successful message publishing.

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

PublisherDeliverer sets the deliverer function that the Publisher invokes.

PublisherTimeout sets the available timeout for a kafka request.

SetLogger returns RequestFunc that sets SDK Logger to the request context.

SetMetrics returns RequestFunc that sets the Metrics client to the request context.

SetRequestID returns RequestFunc that sets RequestID to the request context if not previously set.

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 subscriber message object before the request is decoded.

SubscriberErrorEncoder is used to encode errors to the subscriber reply whenever they're encountered in the processing of a request.

SubscriberErrorHandler is used to handle non-terminal errors.

SubscriberFinalizer is executed at the end of every message processing.

SyncDeliverer is a deliverer that publishes the specified message and returns the first object.

Publisher wraps single Kafka topic for message publishing and implements endpoint.Endpoint.

Subscriber wraps an endpoint and provides a handler for kafka messages.

Handler is a handler interface to make testing possible.

DecodeRequestFunc extracts a user-domain request object from an Kafka message.

DecodeResponseFunc extracts a user-domain response object from kafka response object.

Deliverer is invoked by the Publisher to publish the specified Message, and to retrieve the appropriate response Event object.

EncodeRequestFunc encodes the passed request object into an Kafka message object.

EncodeResponseFunc encodes the passed response object into a Kafka message object.

ErrorEncoder is responsible for encoding an error to the subscriber reply.

PublisherOption sets an optional parameter for publishers.

PublisherResponseFunc may take information from a request context.

RequestFunc may take information from a Kafka message and put it into a request context.

SubscriberFinalizerFunc can be used to perform work at the end of message processing, after the response has been constructed.

SubscriberOption sets an optional parameter for subscribers.

SubscriberResponseFunc may take information from a request context and use it to manipulate a Publisher.