Versions in this module Expand all Collapse all v1 v1.5.0 Feb 2, 2018 Changes in this version + const ConsumerMetadataReqKind + const CorrelationTypeGroup + const CorrelationTypeTransaction + const FetchReqKind + const KafkaV0 + const KafkaV1 + const KafkaV2 + const KafkaV3 + const KafkaV4 + const KafkaV5 + const MetadataReqKind + const OffsetCommitReqKind + const OffsetFetchReqKind + const OffsetReqKind + const OffsetReqTimeEarliest + const OffsetReqTimeLatest + const ProduceReqKind + const RequiredAcksAll + const RequiredAcksLocal + const RequiredAcksNone + var ErrBrokerNotAvailable = &KafkaError + var ErrClusterAuthorizationFailed = &KafkaError + var ErrGroupAuthorizationFailed = &KafkaError + var ErrIllegalGeneration = &KafkaError + var ErrInconsistentPartitionAssignmentStrategy = &KafkaError + var ErrInvalidArrayLen = errors.New("invalid array length") + var ErrInvalidCommitOffsetSize = &KafkaError + var ErrInvalidMessage = &KafkaError + var ErrInvalidMessageSize = &KafkaError + var ErrInvalidRequiredAcks = &KafkaError + var ErrInvalidSessionTimeout = &KafkaError + var ErrInvalidTimeStamp = &KafkaError + var ErrInvalidTopic = &KafkaError + var ErrLeaderNotAvailable = &KafkaError + var ErrMessageSizeTooLarge = &KafkaError + var ErrNetwork = &KafkaError + var ErrNoCoordinator = &KafkaError + var ErrNotCoordinator = &KafkaError + var ErrNotEnoughData = errors.New("not enough data") + var ErrNotEnoughReplicas = &KafkaError + var ErrNotEnoughReplicasAfterAppend = &KafkaError + var ErrNotLeaderForPartition = &KafkaError + var ErrOffsetLoadInProgress = &KafkaError + var ErrOffsetMetadataTooLarge = &KafkaError + var ErrOffsetOutOfRange = &KafkaError + var ErrRebalanceInProgress = &KafkaError + var ErrRecordListTooLarge = &KafkaError + var ErrReplicaNotAvailable = &KafkaError + var ErrRequestTimeout = &KafkaError + var ErrScaleControllerEpoch = &KafkaError + var ErrTopicAuthorizationFailed = &KafkaError + var ErrUnknown = &KafkaError + var ErrUnknownConsumerID = &KafkaError + var ErrUnknownParititonAssignmentStrategy = &KafkaError + var ErrUnknownTopicOrPartition = &KafkaError + func ComputeCrc(m *Message, compression Compression) uint32 + func ConfigureParser(c ParserConfig) error + func NewDecoder(r io.Reader) *decoder + func NewEncoder(w io.Writer) *encoder + func ReadReq(r io.Reader) (requestKind int16, b []byte, err error) + func ReadResp(r io.Reader) (correlationID int32, b []byte, err error) + type Compression int8 + const CompressionGzip + const CompressionNone + const CompressionSnappy + type ConsumerMetadataReq struct + ClientID string + ConsumerGroup string + CoordinatorType int8 + CorrelationID int32 + Version int16 + func ReadConsumerMetadataReq(r io.Reader) (*ConsumerMetadataReq, error) + func (r *ConsumerMetadataReq) Bytes() ([]byte, error) + func (r *ConsumerMetadataReq) WriteTo(w io.Writer) (int64, error) + type ConsumerMetadataResp struct + CoordinatorHost string + CoordinatorID int32 + CoordinatorPort int32 + CorrelationID int32 + Err error + ErrMsg string + ThrottleTime time.Duration + Version int16 + func ReadConsumerMetadataResp(r io.Reader) (*ConsumerMetadataResp, error) + func (r *ConsumerMetadataResp) Bytes() ([]byte, error) + type FetchReq struct + ClientID string + CorrelationID int32 + IsolationLevel int8 + MaxBytes int32 + MaxWaitTime time.Duration + MinBytes int32 + ReplicaID int32 + Topics []FetchReqTopic + Version int16 + func ReadFetchReq(r io.Reader) (*FetchReq, error) + func (r *FetchReq) Bytes() ([]byte, error) + func (r *FetchReq) WriteTo(w io.Writer) (int64, error) + type FetchReqPartition struct + FetchOffset int64 + ID int32 + LogStartOffset int64 + MaxBytes int32 + type FetchReqTopic struct + Name string + Partitions []FetchReqPartition + type FetchResp struct + CorrelationID int32 + ThrottleTime time.Duration + Topics []FetchRespTopic + Version int16 + func ReadFetchResp(r io.Reader) (*FetchResp, error) + func (r *FetchResp) Bytes() ([]byte, error) + type FetchRespAbortedTransaction struct + FirstOffset int64 + ProducerID int64 + type FetchRespPartition struct + AbortedTransactions []FetchRespAbortedTransaction + Err error + ID int32 + LastStableOffset int64 + LogStartOffset int64 + Messages []*Message + TipOffset int64 + type FetchRespTopic struct + Name string + Partitions []FetchRespPartition + type KafkaError struct + func (err *KafkaError) Errno() int + func (err *KafkaError) Error() string + type Message struct + Crc uint32 + Key []byte + Offset int64 + Partition int32 + TipOffset int64 + Topic string + Value []byte + type MetadataReq struct + AllowAutoTopicCreation bool + ClientID string + CorrelationID int32 + Topics []string + Version int16 + func ReadMetadataReq(r io.Reader) (*MetadataReq, error) + func (r *MetadataReq) Bytes() ([]byte, error) + func (r *MetadataReq) WriteTo(w io.Writer) (int64, error) + type MetadataResp struct + Brokers []MetadataRespBroker + ClusterID string + ControllerID int32 + CorrelationID int32 + ThrottleTime time.Duration + Topics []MetadataRespTopic + Version int16 + func ReadMetadataResp(r io.Reader) (*MetadataResp, error) + func (r *MetadataResp) Bytes() ([]byte, error) + type MetadataRespBroker struct + Host string + NodeID int32 + Port int32 + Rack string + type MetadataRespPartition struct + Err error + ID int32 + Isrs []int32 + Leader int32 + Replicas []int32 + type MetadataRespTopic struct + Err error + IsInternal bool + Name string + Partitions []MetadataRespPartition + type OffsetCommitReq struct + ClientID string + ConsumerGroup string + CorrelationID int32 + GroupGenerationID int32 + MemberID string + RetentionTime int64 + Topics []OffsetCommitReqTopic + Version int16 + func ReadOffsetCommitReq(r io.Reader) (*OffsetCommitReq, error) + func (r *OffsetCommitReq) Bytes() ([]byte, error) + func (r *OffsetCommitReq) WriteTo(w io.Writer) (int64, error) + type OffsetCommitReqPartition struct + ID int32 + Metadata string + Offset int64 + TimeStamp time.Time + type OffsetCommitReqTopic struct + Name string + Partitions []OffsetCommitReqPartition + type OffsetCommitResp struct + CorrelationID int32 + ThrottleTime time.Duration + Topics []OffsetCommitRespTopic + Version int16 + func ReadOffsetCommitResp(r io.Reader) (*OffsetCommitResp, error) + func (r *OffsetCommitResp) Bytes() ([]byte, error) + type OffsetCommitRespPartition struct + Err error + ID int32 + type OffsetCommitRespTopic struct + Name string + Partitions []OffsetCommitRespPartition + type OffsetFetchReq struct + ClientID string + ConsumerGroup string + CorrelationID int32 + Topics []OffsetFetchReqTopic + Version int16 + func ReadOffsetFetchReq(r io.Reader) (*OffsetFetchReq, error) + func (r *OffsetFetchReq) Bytes() ([]byte, error) + func (r *OffsetFetchReq) WriteTo(w io.Writer) (int64, error) + type OffsetFetchReqTopic struct + Name string + Partitions []int32 + type OffsetFetchResp struct + CorrelationID int32 + Err error + ThrottleTime time.Duration + Topics []OffsetFetchRespTopic + Version int16 + func ReadOffsetFetchResp(r io.Reader) (*OffsetFetchResp, error) + func (r *OffsetFetchResp) Bytes() ([]byte, error) + type OffsetFetchRespPartition struct + Err error + ID int32 + Metadata string + Offset int64 + type OffsetFetchRespTopic struct + Name string + Partitions []OffsetFetchRespPartition + type OffsetReq struct + ClientID string + CorrelationID int32 + IsolationLevel int8 + ReplicaID int32 + Topics []OffsetReqTopic + Version int16 + func ReadOffsetReq(r io.Reader) (*OffsetReq, error) + func (r *OffsetReq) Bytes() ([]byte, error) + func (r *OffsetReq) WriteTo(w io.Writer) (int64, error) + type OffsetReqPartition struct + ID int32 + MaxOffsets int32 + TimeMs int64 + type OffsetReqTopic struct + Name string + Partitions []OffsetReqPartition + type OffsetResp struct + CorrelationID int32 + ThrottleTime time.Duration + Topics []OffsetRespTopic + Version int16 + func ReadOffsetResp(r io.Reader) (*OffsetResp, error) + func (r *OffsetResp) Bytes() ([]byte, error) + type OffsetRespPartition struct + Err error + ID int32 + Offsets []int64 + TimeStamp time.Time + type OffsetRespTopic struct + Name string + Partitions []OffsetRespPartition + type ParserConfig struct + SimplifiedMessageSetParsing bool + type ProduceReq struct + ClientID string + Compression Compression + CorrelationID int32 + RequiredAcks int16 + Timeout time.Duration + Topics []ProduceReqTopic + TransactionalID string + Version int16 + func ReadProduceReq(r io.Reader) (*ProduceReq, error) + func (r *ProduceReq) Bytes() ([]byte, error) + func (r *ProduceReq) WriteTo(w io.Writer) (int64, error) + type ProduceReqPartition struct + ID int32 + Messages []*Message + type ProduceReqTopic struct + Name string + Partitions []ProduceReqPartition + type ProduceResp struct + CorrelationID int32 + ThrottleTime time.Duration + Topics []ProduceRespTopic + Version int16 + func ReadProduceResp(r io.Reader) (*ProduceResp, error) + func (r *ProduceResp) Bytes() ([]byte, error) + type ProduceRespPartition struct + Err error + ID int32 + LogAppendTime int64 + Offset int64 + type ProduceRespTopic struct + Name string + Partitions []ProduceRespPartition Incompatible versions in this module v2.0.7+incompatible May 21, 2019 v2.0.6+incompatible May 21, 2019 v2.0.5+incompatible Jan 21, 2019 v2.0.4+incompatible Aug 28, 2018 v2.0.3+incompatible Jun 26, 2018 v2.0.2+incompatible Apr 27, 2018 v2.0.1+incompatible Apr 17, 2018 v2.0.0+incompatible Apr 17, 2018
Go to main page