From 6c66f780d60e2cc8bd84c61f91f66cfb4149a2b2 Mon Sep 17 00:00:00 2001 From: Jonathan Leaver Date: Fri, 29 Jul 2016 20:22:36 -0400 Subject: [PATCH] resolves https://github.com/Jroland/kafka-net/issues/66 --- src/kafka-net/Producer.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/kafka-net/Producer.cs b/src/kafka-net/Producer.cs index a86dde3d..c72dd3e4 100644 --- a/src/kafka-net/Producer.cs +++ b/src/kafka-net/Producer.cs @@ -126,7 +126,7 @@ public async Task> SendMessageAsync(string topic, IEnumera _asyncCollection.AddRange(batch); - await Task.WhenAll(batch.Select(x => x.Tcs.Task)); + await Task.WhenAll(batch.Select(x => x.Tcs.Task)).ConfigureAwait(false); return batch.Select(topicMessage => topicMessage.Tcs.Task.Result) .Distinct()