kafkagoframe

Aug 22, 2023

Changes in this version

+ const KafkaGoProducerIndexContext — linux/amd64

+ func ReaderFetchMessage(r *kafka.Reader, ctx context.Context) (kafka.Message, error) — linux/amd64

+ func WrapReaderFetchMessage(r *kafka.Reader, ctx context.Context) (kafka.Message, error) — linux/amd64

+ func WrapwriterWriteMessages(w *kafka.Writer, ctx context.Context, msgs ...kafka.Message) error — linux/amd64