Consumer.Close() blocks indefinitely after unhandled exception in PartitionsRevokedHandler

[Rytisk]

Description

The issue I'm facing is that a call to consumer.Close() blocks indefinitely after an unhandled exception occurs inside PartitionsRevokedHandler.

Version: Confluent.Kafka = v1.4.2 OS: Windows 10

How to reproduce

static void Main(string[] args)
{
    var consumer = new ConsumerBuilder<string, string>(new ConsumerConfig 
    {
        EnableAutoOffsetStore = false,
        BootstrapServers = "...",
        GroupId = "group",
    }).SetPartitionsRevokedHandler((c, p) =>
    {
        throw new Exception(); //unhandled exception
    }).Build();

    consumer.Subscribe("topic");
    try 
    {
        while (true)
        {
            var msg = consumer.Consume(TimeSpan.FromSeconds(2));
        }
    }
    catch(Exception ex)
    {
        //catches the exception thrown in PartitionsRevokedHandler
        Console.WriteLine(ex); 
    }
    finally
    {
        //blocks indefinitely
        consumer.Close();
    }
}

Checklist

Please provide the following information:

• [x] A complete (i.e. we can run it), minimal program demonstrating the problem. No need to supply a project file.
• [x] Confluent.Kafka nuget version.
• [ ] Apache Kafka version.
• [x] Client configuration.
• [x] Operating system.
• [ ] Provide logs (with "debug" : "..." as necessary in configuration).
• [ ] Provide broker log excerpts.
• [ ] Critical issue.

[mhowlett]

the root cause of the problem is exceptions don't propagate through native code. in v1.4.0, Confluent.Kafka now handles this explicitly in the producer case, but it's not implemented for the consumer handlers. thanks for noting, we should fix this.

[ajmlima]

Is there any news about this? I'm facing this issue in v1.9.3