search

Jroland / kafka-net

Native C# client for Kafka queue servers.
Apache License 2.0
482 stars 232 forks source link

I am getting KafkaNet.Protocol.ResponseTimeoutException when sending data to kafka topic.Is there any way to overcome this issue? #112

Open dhinesh-raja opened 7 years ago

dhinesh-raja commented 7 years ago

An exception of type 'KafkaNet.Protocol.KafkaApplicationException' occurred in mscorlib.dll but was not handled in user code

Additional information: An exception occured while executing a send operation against http://13.71.116.17:9092/ Topic:LiveCoin-ETHBTC-Ticker PartitionId:1. Exception:System.AggregateException: One or more errors occurred. ---> KafkaNet.Protocol.ResponseTimeoutException: Timeout Expired. Client failed to receive a response from server after waiting 00:01:00ms.

at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)

at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)

at KafkaNet.KafkaConnection.d__4`1.MoveNext()

--- 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.ValidateEnd(Task task)

at KafkaNet.Producer.d__3d.MoveNext()

--- End of inner exception stack trace ---

---> (Inner Exception #0) KafkaNet.Protocol.ResponseTimeoutException: Timeout Expired. Client failed to receive a response from server after waiting 00:01:00ms.

at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)

at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)

at KafkaNet.KafkaConnection.d__4`1.MoveNext()

--- 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.ValidateEnd(Task task)

at KafkaNet.Producer.d__3d.MoveNext()<---