Kafka Consumer for .NET Core

KafkaConsumer.csproj

<Project Sdk="Microsoft.NET.Sdk">                                                                                                                                                                           
  <PropertyGroup>
    <OutputType>Exe</OutputType>
    <TargetFramework>netcoreapp2.0</TargetFramework>
  </PropertyGroup>
  <ItemGroup>
    <PackageReference Include="Confluent.Kafka" Version="0.11.2" />
  </ItemGroup>
</Project>

Program.cs

namespace KafkaConsumer
{
  using System;
  using System.Collections.Generic;
  using System.Text;
  using Confluent.Kafka;
  using Confluent.Kafka.Serialization;

  public class Program
  {
    static void Main(string[] args)
    {
      var config = new Dictionary<string, object>
      {
          { "group.id", "sample-consumer" },
          { "bootstrap.servers", "localhost:9092" },
          { "enable.auto.commit", "false"}
      };

      using (var consumer = new Consumer<Null, string>(config, null, new StringDeserializer(Encoding.UTF8)))
      {                
        consumer.Subscribe(new string[]{"hello-topic"});

        consumer.OnMessage += (_, msg) => 
        {
          Console.WriteLine($"Topic: {msg.Topic} Partition: {msg.Partition} Offset: {msg.Offset} {msg.Value}");
          consumer.CommitAsync(msg);
        };

        while (true)
        {
            consumer.Poll(100);
        }
      }
    }
  }
}