ChenghuaMi

测试成功了，但是没有答应出SQL 语句

2

-------> before id : 29 update= false catid : 6 update= false modelid : 2 update= false title : 案例展示 update= false thumb : https://img.staticdj.com/5db9190f2c7cfa1b8dcd1572b1862965_1080x.jpg update= false keywords : update=...

The offset is submitted, but each execution still starts from the beginning and repeats

1

func main() { r := kafka.NewReader(kafka.ReaderConfig{ Brokers: []string{"localhost:9092"}, Topic: "my-topic", Partition: 0, MaxBytes: 10e6, // 10MB }) for { m, err := r.ReadMessage(context.Background()) if err != nil { break }...