Skip to content
New issue

Have a question about this project? # for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “#”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? # to your account

Add CreateTopics support to kafka-python's AdminClient #1104

Closed
vineetgoel opened this issue May 16, 2017 · 3 comments
Closed

Add CreateTopics support to kafka-python's AdminClient #1104

vineetgoel opened this issue May 16, 2017 · 3 comments

Comments

@vineetgoel
Copy link

From what I know, currently there is support for creating topics only with the client.ensure_topic_exists. It would be nice to be able to create topics using the Kafka Create Topics protocol mentioned here: https://kafka.apache.org/protocol#The_Messages_CreateTopics

This would be useful for programmatically creating topics with custom configs/partition number.

@vineetgoel
Copy link
Author

Looks like the protocol structs are defined: https://github.com/dpkp/kafka-python/blob/master/kafka/protocol/admin.py#L51-L87 but I can't seem to find its usage. Am I missing something here?

@tvoinarovskyi
Copy link
Collaborator

No, you are correct, there is still no implementation for AdminClient. There's an open issue #935 for this. The main problem, as far as I remember, is that Java's Kafka still does not have an interface for this too. It will be released in 0.11 ~ mid summer. I would expect kafka-python to follow up shortly.

@jeffwidman jeffwidman changed the title Create Topics with Kafka Create Topics Protocol Add CreateTopics support to kafka-python's AdminClient May 18, 2017
@jeffwidman
Copy link
Contributor

This landed in #1540, many thanks to @llamahunter

# for free to join this conversation on GitHub. Already have an account? # to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

3 participants