经过多次重试和修改bat文件,我终于成功地在Windows7下运行了Kafka和Zookeeper。这是一台运行Java 7的32位机器。不幸的是,我无法创建主题。我尝试使用这里的教程:C:\Cambria\kafka_2.8.0-0.8.0>bin\kafka-create-topic.bat --zookeeper本地主机:2181--副本handleArgument(OptionParserState.java:59)
at joptsimple.OptionParser.pars
多亏了confluent_kafka.admin.AdminClient,我才得以检查我的集群中副本的配置 # meta is kafka's ClusterMetadata for repl in partition.replicas: print("replica not in broker"
我正在为Kafka使用Python高级使用者,并想知道每个主题分区的最新偏移量。但是我不能让它起作用。from kafka import TopicPartitionps = [TopicPartition(topic, p) for p in con.partitions_for_topic(topic)]
con.assign(ps)但结