Versions in this module Expand all Collapse all v1 v1.0.0 Aug 4, 2023 Changes in this version + const KafkaMaxBytes + const KafkaMaxWait + type KafkaClient struct + func NewKafkaClient(topic string, readerLastOffset int64, addrs ...string) (*KafkaClient, error) + func (k *KafkaClient) Broadcast(ctx context.Context, info *pb.BlockInfo) error + func (k *KafkaClient) Fetch(ctx context.Context) (infos []*pb.BlockInfo, err error) + func (k *KafkaClient) FetchStart(ctx context.Context, start int64) (infos []*pb.BlockInfo, err error) + func (k *KafkaClient) IncrementLastReaderOffset() + func (k *KafkaClient) LastReaderOffset() int64 + func (k *KafkaClient) LastWriterOffset() int64 + func (k *KafkaClient) RemoteOffset() (firstOffset int64, lastOffset int64, err error) + func (k *KafkaClient) ResetLastReaderOffset(offset int64) + func (k *KafkaClient) ResetTopic(topic string)
Go to main page