v0.14.0
Implemented:
- Added HTTP API endpoints to list topics optionally with partitions and
configuration. - Ack timeout can now be greater than subscription timeout. So in absence of
incoming consume requests for a topic, rebalancing may be delayed until
ack timeout expires for all offered messages. If a new request comes while
waiting for ack timeout to expire, then the subscription timer is reset for
the topic. - Posts can now be performed with content type
x-www-form-urlencoded
, in that
case message should be passed in themsg
form parameter. - Structural logging with sirupsen/logrus and mailgun/logrus-hooks/kafkahook.
- Support for Kafka version 0.10.2.0.
Fixed:
- Explicit acks were fixed for HTTP API. Turned out values of
noAck
,
ackPartition
, andackOffset
parameters had been ignored. - A race was found in tests that if a request comes while a topic expiration
is in progress consumption from the topic may never resume. - #100 Consumption from a
partition stops if the segment that we read from expires.