in src/Epam.Kafka.PubSub/Publication/Topics/PublicationTopicWrapper.cs [82:111]
private static void ConfigureReports(ProducerConfig config)
{
const string timestamp = "timestamp";
const string status = "status";
config.EnableDeliveryReports = true;
if (string.IsNullOrWhiteSpace(config.DeliveryReportFields))
{
config.DeliveryReportFields = $"{timestamp},{status}";
}
else if (!string.Equals("all", config.DeliveryReportFields, StringComparison.OrdinalIgnoreCase))
{
var items = config.DeliveryReportFields.Split(',').ToList();
if (!items.Any(x => string.Equals(timestamp, x, StringComparison.OrdinalIgnoreCase)))
{
items.Add(timestamp);
}
if (!items.Any(x => string.Equals(status, x, StringComparison.OrdinalIgnoreCase)))
{
items.Add(status);
}
config.DeliveryReportFields = string.Join(",", items);
}
config.DeliveryReportFields = config.DeliveryReportFields.ToLowerInvariant();
}