diff --git a/check/setup.go b/check/setup.go index 3f26ce7..35170eb 100644 --- a/check/setup.go +++ b/check/setup.go @@ -170,7 +170,8 @@ func (check *HealthCheck) createTopic(name string, forHealthCheck bool) (err err if !exists { topicConfig := `{"version":1,"config":{"delete.retention.ms":"10000",` + - `"cleanup.policy":"delete","compression.type":"uncompressed"}}` + `"cleanup.policy":"delete","compression.type":"uncompressed",` + + `"min.insync.replicas":"1"}}` log.Infof(`creating topic "%s" configuration node`, name) if err = createZkNode(zkConn, topicPath, topicConfig, forHealthCheck); err != nil {