Merge pull request #612 from wonderflow/fixkafka1

fix kafka with errors return
qiniu · Jul 18, 2018 · d73c47b · d73c47b
2 parents 096fcd7 + 3c5ba60
commit d73c47b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/reader/kafka/kafka.go b/reader/kafka/kafka.go
@@ -81,6 +81,7 @@ func NewReader(meta *reader.Meta, conf conf.MapConf) (reader.Reader, error) {
 	config := consumergroup.NewConfig()
 	config.Zookeeper.Chroot = kr.ZookeeperChroot
 	config.Zookeeper.Timeout = kr.ZookeeperTimeout
+	config.Consumer.Return.Errors = true
 
 	/*********************  kafka offset *************************/
 	/* 这里设定的offset不影响原有的offset，因为kafka client会去获取   */

diff --git a/reader/rest_reader_models.go b/reader/rest_reader_models.go
@@ -162,7 +162,7 @@ var (
 		{ModePostgreSQL, "从 PostgreSQL 读取"},
 		{ModeElastic, "从 Elasticsearch 读取"},
 		{ModeMongo, "从 MongoDB 读取"},
-		{ModeKafka, "从 Kafka 读取"},
+		{ModeKafka, "从 Kafka 读取 (针对0.8及以前版本)"},
 		{ModeRedis, "从 Redis 读取"},
 		{ModeSocket, "从 Socket 读取"},
 		{ModeHTTP, "从 http 请求中读取"},