Peng Peidong

愿所有愿望都实现 ：）

看着标题就想我奶奶了，愿繁星永耀~

> see see this [example](https://pkg.go.dev/github.com/segmentio/kafka-go#example-Generation.Start-ConsumerGroupParallelReaders) this example is for consumer group, not for standalone consumer

> try https://github.com/segmentio/kafka-go/blob/v0.4.32/conn.go#L962 ? thank you. this method gets partition info for the given topics, not subscribes the given topics.

> https://github.com/segmentio/kafka-go/blob/v0.4.32/reader.go#L363 // GroupTopics allows specifying multiple topics, but can only be used in // combination with GroupID, as it is a consumer-group feature.

haha, I don‘t want use consumer group

thank for your reply. I am using kafka for the first time

Hi @achille-roussel In my situation, because messages are time-sensitive, so I only need to consume messages from the latest offset.

请问后面两种线程模型分别理解为协程和golang goroutine吗？

第一天get,学框架的同时学习go。主要学习到：1. struct添加method 2. go mod 使用