Description
Description
I am able to list existing topics but I am not able to create a new topic or change partitions to an existing topic
Failed to create topic EDW_TEST_DATA: KafkaError{code=_TIMED_OUT,val=-185,str="Timed out waiting for controller"}
How to reproduce
import confluent_kafka.admin, pprint
conf = {'bootstrap.servers': 'localhost:9092'}
kafka_admin = confluent_kafka.admin.AdminClient(conf)
topics = ['EDW_TEST_DATA']
new_topics = [confluent_kafka.admin.NewTopic(topic, num_partitions=3, replication_factor=1) for topic in topics]
fs = kafka_admin.create_topics(new_topics)
for topic, f in fs.items():
try:
f.result() # The result itself is None
print("Topic {} created".format(topic))
except Exception as e:
print("Failed to create topic {}: {}".format(topic, e))
pprint.pprint(kafka_admin.list_topics().topics)
topic_list = []
topic_list.append(confluent_kafka.admin.NewPartitions('EDW_EMP_DATA1', 3))
kafka_admin.create_partitions(topic_list)
pprint.pprint(kafka_admin.list_topics().topics)
Checklist
Please provide the following information:
- [X ] confluent-kafka-python and librdkafka version (
confluent_kafka.version()andconfluent_kafka.libversion()): ('1.1.0', 16842752) and ('1.1.0', 16843007) - Apache Kafka broker version:
- Client configuration:
{...} - [X ] Operating system: MacOS 10.14
- Provide client logs (with
'debug': '..'as necessary) - Provide broker log excerpts
- Critical issue