plum

 by kafka

 if don't read old msg,maybe it will lose data not to be handled,so whether open this param for user?

> Definitely good suggestion with clustering. > > Regarding LastOffset, it means last non-committed message, at least as far as I know. You definitely don't want to read from the...

This is my consumer group code like this: consumer group config: config.Consumer.Offsets.Initial = sarama.OffsetOldest config.Consumer.Offsets.AutoCommit.Enable = false config.Consumer.Return.Errors = true Other config is default, and kafka did not happen rebalance....

kafka consumer写在了data层， 但没有做具体实现，，， 我目前把consumer放在了service， producer放在了data。

Have you solved it? I have the same need

> @daiki-sone have you tried using the options? You can see an example here: https://github.com/google/gnostic/blob/main/cmd/protoc-gen-openapi/examples/tests/openapiv3annotations/message.proto#L63 > > The MediaType message has an `examples` property so I think you can set...

Hi, have any plans to release a version with #359? because source_relative option is useful

> Yes, it is supported. See example: https://github.com/citilinkru/camunda-client-go/blob/master/examples/processor/processor.go This example is handling for completing external service task, not for recalling it. Sorry, I can not find relative examples.

Yes, it can't work on version0.1.9 about history conversation! ex: conversatons = []sting{"what is phone number", "this phone number is 123456"}， but result is I don't know (no error).It discards...