Kafka Go Versions Save

Kafka library in Go

v0.4.39

1 year ago

What's Changed

Removed the outdated part of the documentation by @maksim77 in https://github.com/segmentio/kafka-go/pull/1030
retract v0.4.36-v0.4.37 by @rhansen2 in https://github.com/segmentio/kafka-go/pull/1045
add WriterData field to the message struct by @3AceShowHand in https://github.com/segmentio/kafka-go/pull/1059
Change comment on MaxAttempts by @C-Pro in https://github.com/segmentio/kafka-go/pull/1077
Use buffer pool for decompressed buffer by @ashishkf in https://github.com/segmentio/kafka-go/pull/1063

New Contributors

@maksim77 made their first contribution in https://github.com/segmentio/kafka-go/pull/1030
@3AceShowHand made their first contribution in https://github.com/segmentio/kafka-go/pull/1059
@C-Pro made their first contribution in https://github.com/segmentio/kafka-go/pull/1077
@ashishkf made their first contribution in https://github.com/segmentio/kafka-go/pull/1063

Full Changelog: https://github.com/segmentio/kafka-go/compare/v0.4.38...v0.4.39

v0.4.38

1 year ago

What's Changed

Revert client consumer group by @rhansen2 in https://github.com/segmentio/kafka-go/pull/1027

Full Changelog: https://github.com/segmentio/kafka-go/compare/v0.4.37...v0.4.38

v0.4.37

1 year ago

What's Changed

Fixes for consumer group by @rhansen2 in https://github.com/segmentio/kafka-go/pull/1022

Full Changelog: https://github.com/segmentio/kafka-go/compare/v0.4.36...v0.4.37

v0.4.36

1 year ago

What's Changed

Fix aws_msk_iam_v2 module Authentication failure bug by @kikyomits in https://github.com/segmentio/kafka-go/pull/977
Use faster gzip package by @klauspost in https://github.com/segmentio/kafka-go/pull/982
Refactor Consumer Group to use Client by @rhansen2 in https://github.com/segmentio/kafka-go/pull/947
#726 make kafka reader message ReadBatchTimeout configurable by @moogacs in https://github.com/segmentio/kafka-go/pull/989
Refine err msg in SetOffsetAt() by @haorenfsa in https://github.com/segmentio/kafka-go/pull/1001
Support for offsetdelete by @a-dot in https://github.com/segmentio/kafka-go/pull/1010
compress/snappy: configurable compression level by @chriso in https://github.com/segmentio/kafka-go/pull/1014
Support metadata request v6 by @mtkopone in https://github.com/segmentio/kafka-go/pull/1013
change writer retries stat from summary to counter by @achille-roussel in https://github.com/segmentio/kafka-go/pull/1008
use useSyncCommits by @wsy6543 in https://github.com/segmentio/kafka-go/pull/1017
Add WriteBackoffMin/Max config to Writer by @halkar in https://github.com/segmentio/kafka-go/pull/1015

New Contributors

@klauspost made their first contribution in https://github.com/segmentio/kafka-go/pull/982
@moogacs made their first contribution in https://github.com/segmentio/kafka-go/pull/989
@haorenfsa made their first contribution in https://github.com/segmentio/kafka-go/pull/1001
@a-dot made their first contribution in https://github.com/segmentio/kafka-go/pull/1010
@chriso made their first contribution in https://github.com/segmentio/kafka-go/pull/1014
@mtkopone made their first contribution in https://github.com/segmentio/kafka-go/pull/1013
@wsy6543 made their first contribution in https://github.com/segmentio/kafka-go/pull/1017
@halkar made their first contribution in https://github.com/segmentio/kafka-go/pull/1015

Full Changelog: https://github.com/segmentio/kafka-go/compare/v0.4.35...v0.4.36

v0.4.35

1 year ago

What's Changed

fix issue 971 by @achille-roussel in https://github.com/segmentio/kafka-go/pull/973
Update WriteErrors error message by @mhmtszr in https://github.com/segmentio/kafka-go/pull/964
feat(reader): handle io.ErrNoProgress more gracefully by @dominicbarnes in https://github.com/segmentio/kafka-go/pull/941

New Contributors

@mhmtszr made their first contribution in https://github.com/segmentio/kafka-go/pull/964

Full Changelog: https://github.com/segmentio/kafka-go/compare/v0.4.34...v0.4.35

v0.4.34

1 year ago

What's Changed

Updated Writer and Reader docs to show use of multiple brokers. by @lakamsani in https://github.com/segmentio/kafka-go/pull/959
feat: added aws-sdk-go-v2 IAM Mechanism for MSK authentication by @kikyomits in https://github.com/segmentio/kafka-go/pull/937

New Contributors

@lakamsani made their first contribution in https://github.com/segmentio/kafka-go/pull/959
@kikyomits made their first contribution in https://github.com/segmentio/kafka-go/pull/937

Full Changelog: https://github.com/segmentio/kafka-go/compare/v0.4.33...v0.4.34

v0.4.33

1 year ago

What's Changed

add consumer group apis to client by @rhansen2 in https://github.com/segmentio/kafka-go/pull/943
Update go dependencies by @mswathi-tw in https://github.com/segmentio/kafka-go/pull/945
fix typos in group structs by @rhansen2 in https://github.com/segmentio/kafka-go/pull/946
protocol: Use standardized result type checking by @nlsun in https://github.com/segmentio/kafka-go/pull/942
fix(protocol): fix type assertion error by @kscooo in https://github.com/segmentio/kafka-go/pull/931
re-order protocol/joingroup response fields by @rhansen2 in https://github.com/segmentio/kafka-go/pull/949

New Contributors

@mswathi-tw made their first contribution in https://github.com/segmentio/kafka-go/pull/945
@kscooo made their first contribution in https://github.com/segmentio/kafka-go/pull/931

Full Changelog: https://github.com/segmentio/kafka-go/compare/v0.4.32...v0.4.33

v0.4.32

2 years ago

What's Changed

fix: don't assume the header count will be positive by @achille-roussel in https://github.com/segmentio/kafka-go/pull/882
improve issue templates by @achille-roussel in https://github.com/segmentio/kafka-go/pull/883
Fix Transport SASL configuration by @PzaThief in https://github.com/segmentio/kafka-go/pull/885
upgrade github.com/klauspost/compress to v1.15.1 and remove the need for runtime finalizers by @achille-roussel in https://github.com/segmentio/kafka-go/pull/889
Bring the list of error codes up to date by @freeformz in https://github.com/segmentio/kafka-go/pull/902
Add "human readable" description for offset in reader logs by @wwade in https://github.com/segmentio/kafka-go/pull/893
build: add golangci-lint to circleci config by @dominicbarnes in https://github.com/segmentio/kafka-go/pull/907
ReferenceHash balancer by @fracasula in https://github.com/segmentio/kafka-go/pull/906
Fix typo in Writer fields documentation by @angristan in https://github.com/segmentio/kafka-go/pull/916
enable errorlint linter and fix issues by @dominicbarnes in https://github.com/segmentio/kafka-go/pull/914
feat: reuse decompressed buffer to avoid allocating buffer whenever a batch is read. Fixes #909 by @vmihailenco in https://github.com/segmentio/kafka-go/pull/920
fix: handle error in response by @rhansen2 in https://github.com/segmentio/kafka-go/pull/925
Reader: allow config to return OffsetOutOfRange errors by @dominicbarnes in https://github.com/segmentio/kafka-go/pull/917

New Contributors

@freeformz made their first contribution in https://github.com/segmentio/kafka-go/pull/902
@wwade made their first contribution in https://github.com/segmentio/kafka-go/pull/893
@fracasula made their first contribution in https://github.com/segmentio/kafka-go/pull/906
@angristan made their first contribution in https://github.com/segmentio/kafka-go/pull/916

Full Changelog: https://github.com/segmentio/kafka-go/compare/v0.4.31...v0.4.32

v0.4.31

2 years ago

What's Changed

Fix logger example by @route in https://github.com/segmentio/kafka-go/pull/871
Fixes tiny typo by @PzaThief in https://github.com/segmentio/kafka-go/pull/875
Add the field to avoid creating missing topic. by @kislerdm in https://github.com/segmentio/kafka-go/pull/873
Improving some internal error-handling by @dominicbarnes in https://github.com/segmentio/kafka-go/pull/846
support saslAuthenticate v0 in protocol package by @rhansen2 in https://github.com/segmentio/kafka-go/pull/869

New Contributors

@route made their first contribution in https://github.com/segmentio/kafka-go/pull/871
@PzaThief made their first contribution in https://github.com/segmentio/kafka-go/pull/875
@kislerdm made their first contribution in https://github.com/segmentio/kafka-go/pull/873

Full Changelog: https://github.com/segmentio/kafka-go/compare/v0.4.30...v0.4.31

v0.4.30

2 years ago

What's Changed

attempt to detect improper TLS config by @rhansen2 in https://github.com/segmentio/kafka-go/pull/843
set ServerName on tls.Config even when InsecureSkipVeriy is true by @rhansen2 in https://github.com/segmentio/kafka-go/pull/860

Full Changelog: https://github.com/segmentio/kafka-go/compare/v0.4.29...v0.4.30