[ 
https://issues.apache.org/jira/browse/KAFKA-6439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16375310#comment-16375310
 ] 
Ewen Cheslack-Postava commented on KAFKA-6439:
----------------------------------------------

You need to follow up with streamsets. This error just indicates that there 
was, at a minimum, a temporary failure to connect with the Kafka cluster. This 
error doesn't indicate a problem with Kafka, just a general issue with the 
connection to the cluster. Usually this means edge cases/availability issues 
are not being handled by the application. Just a guess, but I suspect it is 
more likely a security protocol issue where streamsets is configured to talk to 
an unsecured cluster but the Kafka endpoint is actually SSL.

I'm going to close this because it looks like it is actually an issue with 
streamsets not handling this exception properly. However, feel free to reopen 
if this gets tracked back to an underlying Kafka issue.

> "com.streamsets.pipeline.api.StageException: KAFKA_50 - Error writing data to 
> the Kafka broker: java.util.concurrent.ExecutionException: 
> org.apache.kafka.common.errors.NetworkException: The server disconnected 
> before a response was received"
> -------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-6439
>                 URL: https://issues.apache.org/jira/browse/KAFKA-6439
>             Project: Kafka
>          Issue Type: Bug
>          Components: network
>    Affects Versions: 0.10.0.1
>         Environment: Ubuntu 64bit
>            Reporter: srithar durairaj
>            Priority: Major
>
> We are using streamset to produce data into kafka topic (3 node cluster). We 
> are facing following error frequently in production.  
> "com.streamsets.pipeline.api.StageException: KAFKA_50 - Error writing data to 
> the Kafka broker: java.util.concurrent.ExecutionException: 
> org.apache.kafka.common.errors.NetworkException: The server disconnected 
> before a response was received"



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to