Versions in this module Expand all Collapse all v1 v1.2.0 Oct 25, 2021 v1.1.0 Oct 23, 2021 Changes in this version + type Heartbeater struct + func NewHeartbeater(client heartbeatProvider) Heartbeater + func (h Heartbeater) Heartbeat(ctx context.Context, req *kafka.HeartbeatRequest, invoker string) (*kafka.HeartbeatResponse, error) + type Reader struct + func NewReader(reader readerProvider) Reader + func (r Reader) Close(invoker string) error + func (r Reader) ReadMessage(ctx context.Context, invoker string) (kafka.Message, error) + type Writer struct + func NewWriter(writer writerProvider) Writer + func (w Writer) Close(invoker string) error + func (w Writer) WriteMessages(ctx context.Context, msgs []kafka.Message, invoker string) error
Go to main page