At the moment producers do not get any support when restarting: where should it start producing data from? what data had been committed successfully in the past?
and also for load distribution there is no support in the Kafka client itself. how many producers for a single source are currently active? which producer reads which tables or database table partitions? Doing something similar as the consumer provides, this can be solved and be made more convenient for the producer developer.
