create

Create an object.

Use this command to create an object on the server to which you are connected. For Apache Kafka, you can create topics, ACLs for topics, clusters, groups and delegation tokens.

Synopsis

create topic <String> partitions <Int> replication-factor <Int> [force | if-not-exists | disable-rack-aware]

create topic <String> replica-assignment <String> [force | if-not-exists | disable-rack-aware]

create topic-acl <String> allow-principal | deny-principal <PrincipalType:name> [force | allow-host <String> | deny-host <String> | operation <String>]

create topic-acl <String> producer allow-principal <String> [force | allow-host <String> | deny-host <String> | operation <String>]

create topic-acl <String> consumer allow-principal <String> [force | allow-host <String> | cluster | transaction-id <String>]

create cluster-acl allow-principal | deny-principal <PrincipalType:name> [force | allow-host <String> | deny-host <String> | operation <String>]

create group-acl <String> allow-principal | deny-principal <PrincipalType:name> [force | allow-host <String> | deny-host <String> | operation <String>]

create delegation-token-acl <String> allow-principal | deny-principal <PrincipalType:name> [force | allow-host <String> | deny-host <String> | operation <String>]

Options

topic <String> partitions <Int> replication-factor <Int>
topic with partitions and replication factor specified
topic <String> replica-assignment <String>
topic specification
topic-acl <String> allow-principal | deny-principal <PrincipalType:name>
topic ACL specification
topic-acl <String> producer allow-principal <String> [force | allow-host <String>
topic ACL specification
cluster-acl allow-principal | deny-principal <PrincipalType:name>
cluster ACL specification
group-acl <String> allow-principal | deny-principal <PrincipalType:name>
group ACL specification
delegation-token-acl <String> allow-principal | deny-principal <PrincipalType:name>
delegation token ACL specification

Optional Arguments

allow-host <String>
ACL option
cluster
ACL producer option
deny-host <String>
ACL option
disable-rack-aware
topic option
force
bypass yes/no prompts
group <String>
ACL consumer option
if-not-exists
topic-only option
operation <String>
ACL option
transaction-id <String>
ACL producer option

Examples

zookeeper@localhost:2181> create topic topic1 partitions 1 replication-factor 2

zookeeper@localhost:2181> create topic topic2 replica-assignment 0:2

zookeeper@localhost:2181> create topic-acl topic2 allow-principal type:Name

zookeeper@localhost:2181> create topic-acl topic1 producer allow-principal type:Name

zookeeper@localhost:2181> create topic-acl topic1 consumer allow-principal type:Name group 0 

zookeeper@localhost:2181> create cluster-acl allow-principal type:Name

zookeeper@localhost:2181> create group-acl 0 allow-principal type:Name

zookeeper@localhost:2181> create delegation-token-acl aclName  allow-principal 

See Also

delete