There is one partition class in pykafka package in partition.py .Could you
please tell me how to use
that class.
On Sun, Feb 26, 2017 at 11:44 PM, Hans Jespersen wrote:
> The Confluent python client does not support this today. If you find a
> python api that does create topic partitions don't e
The Confluent python client does not support this today. If you find a
python api that does create topic partitions don't expect it to work with a
secure Kafka cluster and expect it to have to be completely re-written in
the near future when the new Kafka Admin API is implemented under the
covers.
My question is can we create partitions in topic using any pythonic API?
On Sun, Feb 26, 2017 at 8:24 PM, Hans Jespersen wrote:
> The current Java AdminUtils are older code that talks to zookeeper and
> does not support a secured Kafka cluster.
> There will be a new Java Admin API in the future
The current Java AdminUtils are older code that talks to zookeeper and does not
support a secured Kafka cluster.
There will be a new Java Admin API in the future that talks to the Kafka
brokers directly using the admin extensions to the Kafka protocol which are
already in the 0.10.2 brokers.
I w
Hi All,
In kafka java driver, we have kafka.admin.AdminUtils class which has
methods like createTopic and addPartitions(). Do we have these type of
class and methods in any of kafka python drivers.If there is please do
suggest.
Thank you .
