Versions in this module Expand all Collapse all v0 v0.7.0 Jul 19, 2023 Changes in this version + const Broadcast + const Chan + const CloudEventsFormat + const CompressionType + const DestinationHub + const FragmentationTimestamp + const Kafka + const KafkaMessageFormat + const Offset + const Size + type Consumer interface + MessageChan func() chan *Message + Start func(ctx context.Context) error + type KafkaConfig struct + BootstrapServer string + CaCertPath string + ClientCertPath string + ClientKeyPath string + ConsumerConfig *KafkaConsumerConfig + EnableTLS bool + ProducerConfig *KafkaProducerConfig + type KafkaConsumerConfig struct + ConsumerID string + ConsumerTopic string + type KafkaProducerConfig struct + MessageSizeLimitKB int + ProducerID string + ProducerTopic string + type Message struct + Destination string + ID string + Key string + MsgType string + Payload []byte + Version string + type Producer interface + Send func(ctx context.Context, msg *Message) error + type TransportConfig struct + CommitterInterval time.Duration + Extends map[string]interface{} + KafkaConfig *KafkaConfig + MessageCompressionType string + TransportFormat string + TransportType string + type TransportFormat string + type TransportType string
Go to main page