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