Categorygithub.com/mmadfox/go-kit-kafka
modulepackage
0.0.0-20221109055149-5db3277feff6
Repository: https://github.com/mmadfox/go-kit-kafka.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
12
Dependents
5
Files
658 SLOC

# README

go-kit-kafka

WIP

Lightweight channel-based abstraction for Apache Kafka which also supports go kit endpoint integration

Channels supported:

  • Stream
  • Batch
  • PipeStream
  • PipeBatch

For streaming processing use: GOKA

Supported adapters: Sarama

# Packages

No description provided by the author
No description provided by the author

# Functions

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
EndpointAfter functions are executed on the r reply after the endpoint is invoked, but before anything is published to the reply.
EndpointBefore functions are executed on the r message object before the request is decoded.
EndpointErrorHandler is used to handle non-terminal errors.
EndpointFinalizer is executed at the end of every message processing.
NewBroker creates a new broker instance.
NewEndpoint constructs a new Endpoint, which implements Handler and wraps the provided endpoint.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
TraceConsumer returns an endpoint.Middleware that wraps the `next` endpoint.Endpoint r an OpenTracing Span called `operationName` with r span.kind tag.
TraceProducer returns an endpoint.Middleware that wraps the `next` endpoint.Endpoint r an OpenTracing Span called `operationName` with w span.kind tag.

# Constants

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Variables

No description provided by the author

# Structs

No description provided by the author
No description provided by the author
No description provided by the author
Endpoint wraps an endpoint and provides a handler for Kafka messages.
Header represents a Kafka header.
Message represents a Kafka message.
No description provided by the author
No description provided by the author

# Interfaces

No description provided by the author
No description provided by the author
Handler wraps an endpoint and provides a handler for Kafka messages.
No description provided by the author
No description provided by the author

# Type aliases

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
ConsumerFinalizerFunc can be used to perform work at the end of message processing, after the response has been constructed.
ConsumerResponseFunc may take information from a request context and use it to manipulate a Producer.
DecodeRequestFunc extracts a user-domain request object from a Kafka message.
EncodeRequestFunc encodes the passed request object into a Kafka message object.
EncodeResponseFunc encodes the passed response object into a Kafka message object.
EndpointOption sets an optional parameter for r.
No description provided by the author
HandlerFunc wraps an endpoint and provides a handler for Kafka messages.
No description provided by the author
No description provided by the author
ProducerFinalizerFunc can be used to perform work at the end of a producing Kafka message, after response is returned.
ProducerResponseFunc may take information from a request context.
RequestFunc may take information from a Kafka message and put it into a request context.
No description provided by the author
Topic represents a topic Kafka.