Kafka: Consumer configuration "auto.offset.reset"

[Amakaev]

Hey, why is "auto.offset.reset" hardly set's to earliest? Can it be configured to latest?
I don't wanna get all topics messages on attaching new consumer group.

CAP/src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs

Lines 109 to 117 in 641d4ac

	var config = new ConsumerConfig(new Dictionary<string, string>(_kafkaOptions.MainConfig))
	{
	BootstrapServers = _kafkaOptions.Servers,
	GroupId = _groupId,
	AutoOffsetReset = AutoOffsetReset.Earliest,
	AllowAutoCreateTopics = true,
	EnableAutoCommit = false,
	LogConnectionClose = false
	};

[yang-xiaodong]

Hello,

Thanks for your feedback , We now support rewriting the default configuration of Kafka consumer, Example:

 x.UseKafka(z =>
  {
      z.Servers = "localhost:9092";
      z.MainConfig.Add("auto.offset.reset", "latest");
  });

[yang-xiaodong]

Issue was fixed in 5.0.1 and released to NuGet a few minutes ago