Versions in this module Expand all Collapse all v0 v0.0.0 Apr 9, 2020 Changes in this version + type KafkaStreamConfig struct + func (_m *KafkaStreamConfig) ChannelProduce(topic *string, value []byte) + func (_m *KafkaStreamConfig) Close() error + func (_m *KafkaStreamConfig) Flush(ms int) int + func (_m *KafkaStreamConfig) FullTopic(t string) string + func (_m *KafkaStreamConfig) GetBrokers() string + func (_m *KafkaStreamConfig) GetConsumer() *kafka.Consumer + func (_m *KafkaStreamConfig) GetPrefix() string + func (_m *KafkaStreamConfig) GetProducer() *kafka.Producer + func (_m *KafkaStreamConfig) NewConsumer(km *kafka.ConfigMap) (*kafka.Consumer, error) + func (_m *KafkaStreamConfig) NewProducer(km *kafka.ConfigMap) (*kafka.Producer, error) + func (_m *KafkaStreamConfig) Produce(topic *string, value []byte) error + func (_m *KafkaStreamConfig) ProducerDefaults() *kafka.ConfigMap + func (_m *KafkaStreamConfig) SetBrokers(brokers string) + func (_m *KafkaStreamConfig) SetDeliveryError(f func(*kafka.Message)) + func (_m *KafkaStreamConfig) SetFlags() + func (_m *KafkaStreamConfig) SetPrefix(prefix string) + func (_m *KafkaStreamConfig) SetTopic(topic string)
Go to main page