Releases: kafka4beam/brod
Releases · kafka4beam/brod
3.16.2
- Update kafka_protocol from 4.0.1 to 4.0.3.
Prior to this change the actual time spent in establishing a
Kafka connection might be longer than desired due to the timeout
being used in SSL upgrade (if enabled), then API version query.
This has been fixed by turning the given timeout config
into a deadline, and the sub-steps will try to meet the deadline.
see more details here: kafka4beam/kafka_protocol#9 - Catch
timeout
and otherDOWN
reasons when makinggen_server
call to
brod_client
,brod_consumer
and producer/consumer supervisor,
and return asReason
in{error, Reason}
.
Previously onlynoproc
reaon is caught. (#492) - Propagate
connect_timeout
config tokpro
API functions astimeout
arg
affected APIs: connect_group_coordinator, create_topics, delete_topics,
resolve_offset, fetch, fold, fetch_committed_offsets (#458) - Fix bad field name in group describe request (#486)
3.15.0: Merge pull request #420 from klarna/jesperes/fix-unknown-types
Fix unknown types (one typo and one missing export)
3.9.4: Merge pull request #362 from zmstone/master
Handle undefined fetcher in fold loop exception