Christopher Kempton

Allow worker name to be separated from process name

5

https://github.com/kafkaex/kafka_ex/blob/a1bd36052f4b212fda62795279775ebbc498c407/lib/kafka_ex/new/client.ex#L40 Requested ``` # additional function argument that can contain [name: my_desired_name] def start_link(args, name, opts) do GenServer.start_link(__MODULE__, [args, name], opts) end OR # where args contains the desired worker...

Support Create Partitions

9

Adds in the ability to create partitions for an existing topic. Adds in the ability for clients to synchronize their topic metadata to pick up new partitions and start a...

Support Create Partitions

1

There are times where creating partitions is needed to scale out a topic. The underlying kafka_protocol library supports the functionality to make the request. When a topic partition change has...