childe / healer

golang lib for kafka

22 stars 18 forks source link

Closed sundy-li closed 5 years ago

sundy-li commented 5 years ago

NewSimpleConsumerWithBrokers 应该和 NewSimpleConsumer 的返回类型一致，返回对应的error

增加一个validateConsumerConfig 方法

sundy-li commented 5 years ago

3

childe commented 5 years ago

和我下午已经提交的一些commit重复了, 所以我先关掉了. (其实config有一个checkvalid方法, 但我之前没有使用上) 生成consumer的函数的返回值保持一致, 这个我会改掉.