KafkaCommonCobraInit commandline common parameter init for Kafka.

KafkaValidateConf validates supplied configuration.

NewErrorMockKafkaFactory - mock.

NewKafkaBridge creates a new KafkaBridge.

NewKafkaCommon constructs a new KafkaCommon instance.

NewMockKafkaFactory - mock.

CircuitBreakerConf defines the YAML config structure for the circuit breaker.

KafkaBridge receives messages from Kafka and dispatches them to go-ethereum over JSON/RPC.

KafkaBridgeConf defines the YAML config structure for a Kafka bridge instance.

KafkaCommonConf - Common configuration for Kafka.

MockKafkaConsumer - mock.

MockKafkaFactory - mock.

MockKafkaProducer - mock.

SaramaKafkaFactory - uses sarama.

KafkaClient is the kafka client.

KafkaCommon is the base interface for bridges that interact with Kafka.

KafkaConsumer provides the interface passed from KafkaCommon to consume messages.

KafkaFactory builds new clients.

KafkaGoRoutines defines goroutines for processing Kafka messages from KafkaCommon.

KafkaProducer provides the interface passed from KafkaCommon to produce messages (subset of sarama).