Versions in this module Expand all Collapse all v0 v0.3.0 Dec 7, 2019 Changes in this version + const PartitionAny + type ConsumerConditions struct + Key string + Value string + type ConsumerErrorHandler func(msg []byte, err error) + type ConsumerHandler func(msg []byte) + type JsonValidator struct + func (jv *JsonValidator) IsReachable(schema schema) bool + func (jv *JsonValidator) ValidateData(msg []byte, schema schema) (bool, error) + type KafkaClient struct + func NewKafkaClient() *KafkaClient + func (kc *KafkaClient) BuildConsumer() (*consumerClient, error) + func (kc *KafkaClient) BuildProducer() (*producerClient, error) + func (kc *KafkaClient) SetConsumerConfig(cfg map[string]interface{}) *KafkaClient + func (kc *KafkaClient) SetProducerConfig(cfg map[string]interface{}) *KafkaClient + func (kc *KafkaClient) SetProducerTopicConfig(topicName string, partitionType int32) *KafkaClient + func (kc *KafkaClient) SetTimeoutPolling(polling int) *KafkaClient + type ProducerHeader struct + Key string + Value string + type Validator interface + IsReachable func(schema schema) bool + ValidateData func(msg []byte, schema schema) (bool, error)
Go to main page