Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

producer

package

Go to main page

Versions in this module

v1

v1.24.0

Dec 3, 2021

Changes in this version

type Flags

+ KeyProtoType string

+ ProtoFiles []string

+ ProtoImportPaths []string

+ ProtosetFiles []string

+ ValueProtoType string

+ type MessageSerializerChain struct

+ func (serializer MessageSerializerChain) CanSerialize(topic string) (bool, error)

+ func (serializer MessageSerializerChain) Serialize(key, value []byte, flags Flags) (*sarama.ProducerMessage, error)

+ type ProtobufMessageSerializer struct

+ func CreateProtobufMessageSerializer(topic string, context protobuf.SearchContext, keyType, valueType string) (*ProtobufMessageSerializer, error)

+ func (serializer ProtobufMessageSerializer) CanSerialize(string) (bool, error)

+ func (serializer ProtobufMessageSerializer) Serialize(key, value []byte, flags Flags) (*sarama.ProducerMessage, error)

v1.23.1

Nov 23, 2021

v1.23.0

Nov 5, 2021

Changes in this version

+ const BASE64

+ const HEX

+ func MurmurHasher() hash.Hash32

+ func NewJVMCompatiblePartitioner(topic string) sarama.Partitioner

+ type AvroMessageSerializer struct

+ func CreateAvroMessageSerializer(topic string, avroSchemaRegistry string) (AvroMessageSerializer, error)

+ func (serializer AvroMessageSerializer) CanSerialize(topic string) (bool, error)

+ func (serializer AvroMessageSerializer) Serialize(key, value []byte, flags Flags) (*sarama.ProducerMessage, error)

+ type DefaultMessageSerializer struct

+ func (serializer DefaultMessageSerializer) CanSerialize(_ string) (bool, error)

+ func (serializer DefaultMessageSerializer) Serialize(key, value []byte, flags Flags) (*sarama.ProducerMessage, error)

+ type Flags struct

+ File string

+ Headers []string

+ Key string

+ KeyEncoding string

+ KeySchemaVersion int

+ LineSeparator string

+ NullValue bool

+ Partition int32

+ Partitioner string

+ RateInSeconds int

+ RequiredAcks string

+ Separator string

+ Silent bool

+ Value string

+ ValueEncoding string

+ ValueSchemaVersion int

+ type MessageSerializer interface

+ CanSerialize func(topic string) (bool, error)

+ Serialize func(key, value []byte, flags Flags) (*sarama.ProducerMessage, error)

+ type Operation struct

+ func (operation *Operation) Produce(topic string, flags Flags) error

Other modules containing this package

github.com/deviceinsight/kafkactl/v5