franz-go contains a feature complete, pure Go library for interacting with Kafka from 0.8.0 through 3.7+. Producing, consuming, transacting, administrating, etc.
BSD 3-Clause "New" or "Revised" License
1.78k
stars
182
forks
source link
kgo: allow record ctx cancelation to propagate a bit more #792
If a record's context is canceled, we now allow it to be failed in two
more locations:
while the producer ID is loading -- we can actually now cancel the
producer ID loading request (which may also benefit people using
transactions that want to force quit the client)
while a sink is backing off due to request failures
For people using transactions, canceling a context now allows you to
force quit in more areas, but the same caveat applies: your client will
likely end up in an invalid transactional state and be unable to
continue.
If a record's context is canceled, we now allow it to be failed in two more locations:
while the producer ID is loading -- we can actually now cancel the producer ID loading request (which may also benefit people using transactions that want to force quit the client)
while a sink is backing off due to request failures
For people using transactions, canceling a context now allows you to force quit in more areas, but the same caveat applies: your client will likely end up in an invalid transactional state and be unable to continue.
For #769.