DeleteTopics deletes the specified topics.
(topics ...string)
| 306 | |
| 307 | // DeleteTopics deletes the specified topics. |
| 308 | func (c *Conn) DeleteTopics(topics ...string) error { |
| 309 | _, err := c.deleteTopics(deleteTopicsRequest{ |
| 310 | Topics: topics, |
| 311 | }) |
| 312 | return err |
| 313 | } |
| 314 | |
| 315 | // findCoordinator finds the coordinator for the specified group or transaction |
| 316 | // |