jet / kafunk

Kafunk: F# Kafka client
https://jet.github.io/kafunk/
Other
160 stars 63 forks source link

Fix Producer batch size bug #185

Closed eulerfx closed 6 years ago

chrnola commented 6 years ago

What would happen if the producer was allowed to publish beyond the max batch size? Would the broker reject it, or could it ultimately manifest as a consumer error (MessageTooBigException)?

eulerfx commented 6 years ago

The broker would reject if the message set is bigger than the max allowed. The consumer could also throw if the fetchMaxBytes is less than the largest message in the set.

chrnola commented 6 years ago

Got it, thanks.