in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaTriggerBindingStrategy.cs [69:87]
public Dictionary<string, object> GetBindingData(KafkaTriggerInput value)
{
if (value == null)
{
throw new ArgumentNullException(nameof(value));
}
var bindingData = new Dictionary<string, object>(StringComparer.OrdinalIgnoreCase);
if (value.IsSingleDispatch)
{
AddBindingData(bindingData, value.GetSingleEventData());
}
else
{
AddBindingData(bindingData, value.Events);
}
return bindingData;
}