private static void ConfigureReports()

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();
    }