src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaTriggerAttributeBindingProvider.cs (1 line): - line 75: // TODO: reuse connections if they match with others in same function app src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/KafkaListener.cs (1 line): - line 345: // TODO: maybe slow down if there isn't much incoming data src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/FunctionExecutorBase.cs (1 line): - line 147: // TODO: add retry logic