Skip to content

Closing and opening connection right after, throws exception #24

@avoxm

Description

@avoxm

Here is the code and the stack trace :

await producer.ConnectAsync();
await producer.CloseAsync(TimeSpan.FromSeconds(10));
await producer.ConnectAsync();
 at System.Reactive.Concurrency.EventLoopScheduler.Schedule[TState](TState state, TimeSpan dueTime, Func`3 action)
   at kafka4net.Utils.WatchdogScheduler.Schedule[TState](TState state, TimeSpan dueTime, Func`3 action) in c:\Users\am\Documents\Visual Studio 2013\Projects\kafka4net\src\Utils\WatchdogScheduler.cs:line 48
   at System.Reactive.Concurrency.LocalScheduler.Schedule[TState](TState state, Func`3 action)
   at System.Reactive.Concurrency.Scheduler.Schedule(IScheduler scheduler, Action action)
   at kafka4net.Utils.AskEx.Ask[T](IScheduler scheduler, Func`1 action) in c:\Users\am\Documents\Visual Studio 2013\Projects\kafka4net\src\Utils\AskEx.cs:line 12
   at kafka4net.Producer.<ConnectAsync>d__29.MoveNext() in c:\Users\am\Documents\Visual Studio 2013\Projects\kafka4net\src\Producer.cs:line 89
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at System.Runtime.CompilerServices.TaskAwaiter.GetResult()
   at Kafka4nConsumer.Program.<KafkaTest>d__1.MoveNext() in c:\Users\am\Documents\Visual Studio 2013\Projects\KafkaConsumer\Kafka4nConsumer\Program.cs:line 140

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions