skafka

type CreateTopicKafka struct {
	Host              string
	PolicyCleanup     string `json:"policy_cleanup"`
	Name              string `json:"name"`
	NumPartitions     int    `json:"partition"`
	ReplicationFactor int    `json:"replication_factor"`
}