Hi:
I am working with spark 2.2.1 and spark kafka 0.10 client integration with 
Kafka brokers using 0.11.
I get the exception - org.apache.kafka.common.errors.NetworkException: The 
server disconnected before a response was received - when the application is 
trying to write to a topic. This exception kills the spark application.
Based on some similar issues I saw on the web I've added the following kafka 
configuration but it has not helped.
acks = 0
request.timeout.ms = 45000
receive.buffer.bytes = 1024000
I've posted this question to apache spark users list but have not received any 
response.  If anyone has any suggestion/pointers, please let me know.
Thanks

Reply via email to