Delete inactive consumers - Githubissues

hoppity / kafka-http-proxy

A proxy that allows applications to use Kafka via HTTP written in NodeJS

Apache License 2.0

3 stars 4 forks source link

Delete inactive consumers #9

Closed ducas closed 8 years ago

ducas commented 8 years ago

Several fixes and features to ensure consumers are handled better

Autocommit happens at the end of a request for messages
Record lastPoll on consumer and use it to determine if a consumer is active/inactive
Delete inactive consumers
Use a default config file
Ensure messages published with null/undefined/not-defined key/partition are handled correctly