Consumer slow when using autoVersions=true

jet / kafunk

Kafunk: F# Kafka client

https://jet.github.io/kafunk/

Other

160 stars 63 forks source link

Consumer slow when using autoVersions=true #188

Closed eulerfx closed 6 years ago

eulerfx commented 6 years ago

When the consumer is configured to use autoVersions=true and used to connect to a v0.10 or greater broker, it uses a lot of CPU. It seems something is up with the protocol. To reproduce, run kafunk.Tests/Consumer.fsx with autoVersions=true.