Todd Palino

The Client only supports a single Kafka version (currently mapped to 0.10.2). It should have a configuration to select the version of the client to support, and use the appropriate...

Python's time is in seconds. Therefore, the config does not mean what we think it means

kafka-assigner should be able to support a configuration file to provide default arguments. This would be things like: - Setting sizer selection and options - Setting a default balance module...

Having problems with custom renderers

5

I'm trying to use custom renderers in my application to support sub and sup tags, and they're not having an effect. I have defined the renderers to use, pulling in...

KAFKA-6559: Iterate record sets before calling Log.append

2

If a Produce request contains multiple record sets for a single topic-partition, it is better to iterate these before calling Log.append. This is because append will process all the sets...

Worker timeout needs to be set too long to account for worker startup

3

(note - I'm not asking for someone to create a solution on this. I want to gauge if a proposed solution would be acceptable as a PR that I would...

Described in #3436 This adds a configuration parameter timeout_delay which allows a user to specify a grace period for workers to start notifying that they are live. This decouples the...