| create-topic: |
| description: Create a new Kafka topic |
| params: |
| topic: |
| type: string |
| description: Topic name |
| partitions: |
| type: integer |
| description: Number of partitions for the topic being created |
| replication: |
| type: integer |
| description: Replication factor for each partition in the topic |
| required: [topic, partitions, replication] |
| additionalProperties: false |
| list-topics: |
| description: List all Kafka topics |
| list-zks: |
| description: List ip:port info for connected Zookeeper servers |
| read-topic: |
| description: Consume an existing kafka topic |
| params: |
| topic: |
| type: string |
| description: Topic name |
| partition: |
| type: integer |
| description: Partition to consume |
| required: [topic, partition] |
| additionalProperties: false |
| smoke-test: |
| description: > |
| Verify that Kafka is working as expected by listing zookeepers, then |
| creating/listing/deleting a topic |
| write-topic: |
| description: Write to a kafka topic |
| params: |
| topic: |
| type: string |
| description: Topic name |
| data: |
| type: string |
| description: Data to write to topic |
| required: [topic, data] |
| additionalProperties: false |
