Documentation
¶
Index ¶
- func New(setters ...Setter) consumer.Consumer
- type Consumer
- type Setter
- func SetBrokers(brokers ...string) Setter
- func SetCommitInterval(commitInterval time.Duration) Setter
- func SetDialer(dialer *kafka.Dialer) Setter
- func SetGroupBalancers(groupBalancers ...kafka.GroupBalancer) Setter
- func SetGroupID(groupID string) Setter
- func SetHeartBeatInterval(heartBeatInterval time.Duration) Setter
- func SetIsolationLevel(isolationLevel kafka.IsolationLevel) Setter
- func SetJoinGroupBackoff(joinGroupBackOff time.Duration) Setter
- func SetKafkaGoLogger(logger logger.LogWriter) Setter
- func SetLogger(logger logger.LogWriter) Setter
- func SetMaxAttempts(maxAttempts int) Setter
- func SetMaxBytes(maxBytes int) Setter
- func SetMaxWait(maxWait time.Duration) Setter
- func SetMinBytes(minBytes int) Setter
- func SetOffsetOutOfRangeError(offsetOutOfRangeError bool) Setter
- func SetPartition(partition int) Setter
- func SetPartitionWatchInterval(partitionWatchInterval time.Duration) Setter
- func SetQueueCapacity(queueCapacity int) Setter
- func SetReadBackoffMax(readBackoffMax time.Duration) Setter
- func SetReadBackoffMin(readBackoffMin time.Duration) Setter
- func SetReadBatchTimeout(readBatchTimeout time.Duration) Setter
- func SetReadLagInterval(readLagInterval time.Duration) Setter
- func SetRebalanceTimeout(rebalanceTimeout time.Duration) Setter
- func SetRetentionTime(retentionTime time.Duration) Setter
- func SetSessionTimeout(sessionTimeout time.Duration) Setter
- func SetStartOffset(startOffset int64) Setter
- func SetWatchPartitionChanges(watchPartitionChanges bool) Setter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
func (*Consumer) AddHandler ¶
type Setter ¶
type Setter func(c *Consumer)
func SetBrokers ¶
func SetCommitInterval ¶
func SetGroupBalancers ¶
func SetGroupBalancers(groupBalancers ...kafka.GroupBalancer) Setter
func SetGroupID ¶
func SetHeartBeatInterval ¶
func SetIsolationLevel ¶
func SetIsolationLevel(isolationLevel kafka.IsolationLevel) Setter
func SetJoinGroupBackoff ¶
func SetKafkaGoLogger ¶
func SetMaxAttempts ¶
func SetMaxBytes ¶
func SetMaxWait ¶
func SetMinBytes ¶
func SetPartition ¶
func SetQueueCapacity ¶
func SetReadBackoffMax ¶
func SetReadBackoffMin ¶
func SetReadBatchTimeout ¶
func SetReadLagInterval ¶
func SetRebalanceTimeout ¶
func SetRetentionTime ¶
func SetSessionTimeout ¶
func SetStartOffset ¶
Source Files
Click to show internal directories.
Click to hide internal directories.