Documentation ¶ Overview ¶ Package kafka instance contains commands for interacting with cluster logic of the service directly instead of through the REST API exposed via the serve command. Index ¶ func NewKafkaCommand(f *factory.Factory) *cobra.Command Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func NewKafkaCommand ¶ func NewKafkaCommand(f *factory.Factory) *cobra.Command Types ¶ This section is empty. Source Files ¶ View all Source files kafka.go Directories ¶ Show internal Expand all Path Synopsis acl aclcmdutil admin create delete flagutil grant list billing consumergroup delete describe groupcmdutil list resetoffset create delete describe flagutil kafkacmdutil list openshift-cluster deregister list openshiftclustercmdutil register promote providers topic consume create delete describe list produce topiccmdutil update update use Click to show internal directories. Click to hide internal directories.