Versions in this module Expand all Collapse all v0 v0.9.2 Oct 19, 2016 Changes in this version + const OffsetBeginning + const OffsetEnd + const OffsetInvalid + const OffsetStored + const PartitionAny + const TimestampCreateTime + const TimestampLogAppendTime + const TimestampNotAvailable + func LibraryVersion() (int, string) + type AssignedPartitions struct + Partitions []TopicPartition + func (e AssignedPartitions) String() string + type BrokerMetadata struct + Host string + ID int32 + Port int + type ConfigMap map[string]ConfigValue + func (m ConfigMap) Set(kv string) error + func (m ConfigMap) SetKey(key string, value ConfigValue) error + type ConfigValue interface + type Consumer struct + func NewConsumer(conf *ConfigMap) (*Consumer, error) + func (c *Consumer) Assign(partitions []TopicPartition) (err error) + func (c *Consumer) Close() (err error) + func (c *Consumer) Commit() ([]TopicPartition, error) + func (c *Consumer) CommitMessage(m *Message) ([]TopicPartition, error) + func (c *Consumer) CommitOffsets(offsets []TopicPartition) ([]TopicPartition, error) + func (c *Consumer) Events() chan Event + func (c *Consumer) GetMetadata(topic *string, allTopics bool, timeoutMs int) (*Metadata, error) + func (c *Consumer) Poll(timeoutMs int) (event Event) + func (c *Consumer) QueryWatermarkOffsets(topic string, partition int32, timeoutMs int) (low, high int64, err error) + func (c *Consumer) String() string + func (c *Consumer) Subscribe(topic string, rebalanceCb RebalanceCb) error + func (c *Consumer) SubscribeTopics(topics []string, rebalanceCb RebalanceCb) (err error) + func (c *Consumer) Unassign() (err error) + func (c *Consumer) Unsubscribe() (err error) + type Error struct + func (e Error) Code() ErrorCode + func (e Error) Error() string + func (e Error) String() string + type ErrorCode int + const ErrAllBrokersDown + const ErrAssignPartitions + const ErrAuthentication + const ErrBadCompression + const ErrBadMsg + const ErrBrokerNotAvailable + const ErrClusterAuthorizationFailed + const ErrConflict + const ErrCritSysResource + const ErrDestroy + const ErrExistingSubscription + const ErrFail + const ErrFs + const ErrGroupAuthorizationFailed + const ErrGroupCoordinatorNotAvailable + const ErrGroupLoadInProgress + const ErrIllegalGeneration + const ErrIllegalSaslState + const ErrInProgress + const ErrInconsistentGroupProtocol + const ErrInvalidArg + const ErrInvalidCommitOffsetSize + const ErrInvalidGroupID + const ErrInvalidMsg + const ErrInvalidMsgSize + const ErrInvalidRequiredAcks + const ErrInvalidSessionTimeout + const ErrInvalidTimestamp + const ErrIsrInsuff + const ErrLeaderNotAvailable + const ErrMsgSizeTooLarge + const ErrMsgTimedOut + const ErrNetworkException + const ErrNoError + const ErrNoOffset + const ErrNodeUpdate + const ErrNotCoordinatorForGroup + const ErrNotEnoughReplicas + const ErrNotEnoughReplicasAfterAppend + const ErrNotImplemented + const ErrNotLeaderForPartition + const ErrOffsetMetadataTooLarge + const ErrOffsetOutOfRange + const ErrOutdated + const ErrPartitionEOF + const ErrPrevInProgress + const ErrQueueFull + const ErrRebalanceInProgress + const ErrRecordListTooLarge + const ErrReplicaNotAvailable + const ErrRequestTimedOut + const ErrResolve + const ErrRevokePartitions + const ErrSsl + const ErrStaleCtrlEpoch + const ErrState + const ErrTimedOut + const ErrTimedOutQueue + const ErrTopicAuthorizationFailed + const ErrTopicException + const ErrTransport + const ErrUnknown + const ErrUnknownGroup + const ErrUnknownMemberID + const ErrUnknownPartition + const ErrUnknownProtocol + const ErrUnknownTopic + const ErrUnknownTopicOrPart + const ErrUnsupportedSaslMechanism + const ErrUnsupportedVersion + const ErrWaitCoord + func (c ErrorCode) String() string + type Event interface + String func() string + type Handle interface + type Message struct + Key []byte + Opaque interface{} + Timestamp time.Time + TimestampType TimestampType + TopicPartition TopicPartition + Value []byte + func (m *Message) String() string + type Metadata struct + Brokers []BrokerMetadata + OriginatingBroker BrokerMetadata + Topics map[string]TopicMetadata + type Offset int64 + func NewOffset(offset interface{}) (Offset, error) + func OffsetTail(relativeOffset Offset) Offset + func (o Offset) Set(offset interface{}) error + func (o Offset) String() string + type OffsetsCommitted struct + Error error + Offsets []TopicPartition + func (o OffsetsCommitted) String() string + type PartitionEOF TopicPartition + func (p PartitionEOF) String() string + type PartitionMetadata struct + Error Error + ID int32 + Isrs []int32 + Leader int32 + Replicas []int32 + type Producer struct + func NewProducer(conf *ConfigMap) (*Producer, error) + func (p *Producer) Close() + func (p *Producer) Events() chan Event + func (p *Producer) Flush(timeoutMs int) int + func (p *Producer) GetMetadata(topic *string, allTopics bool, timeoutMs int) (*Metadata, error) + func (p *Producer) Len() int + func (p *Producer) Produce(msg *Message, deliveryChan chan Event) error + func (p *Producer) ProduceChannel() chan *Message + func (p *Producer) QueryWatermarkOffsets(topic string, partition int32, timeoutMs int) (low, high int64, err error) + func (p *Producer) String() string + type RebalanceCb func(*Consumer, Event) error + type RevokedPartitions struct + Partitions []TopicPartition + func (e RevokedPartitions) String() string + type TimestampType int + func (t TimestampType) String() string + type TopicMetadata struct + Error Error + Partitions []PartitionMetadata + Topic string + type TopicPartition struct + Error error + Offset Offset + Partition int32 + Topic *string + func (p TopicPartition) String() string v0.9.2-RC1 Oct 19, 2016