spark-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hyukjin Kwon (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (SPARK-25731) Spark Structured Streaming Support for Kafka 2.0
Date Wed, 17 Oct 2018 08:53:00 GMT

     [ https://issues.apache.org/jira/browse/SPARK-25731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Hyukjin Kwon resolved SPARK-25731.
----------------------------------
    Resolution: Duplicate

> Spark Structured Streaming Support for Kafka 2.0
> ------------------------------------------------
>
>                 Key: SPARK-25731
>                 URL: https://issues.apache.org/jira/browse/SPARK-25731
>             Project: Spark
>          Issue Type: Improvement
>          Components: Structured Streaming
>    Affects Versions: 2.3.2
>            Reporter: Chandan
>            Priority: Major
>              Labels: beginner, features
>
> [https://github.com/apache/spark/tree/master/external]
> As far as I can see, 
>  This doesn't have support for newly release *kafka2.0,*
>  support is available only till *kafka-0-10.*
> If we use the 
> "org.apache.spark" %% "spark-streaming-kafka-0-10" % "2.3.0"
> for kafka2.0, below is the error I get
> 11:46:18.061 [stream execution thread for [id = e393ea37-8009-4ce0-b996-94f767994fb8,
runId = bc15eb7d-876d-4e01-8ee5-22205ec7fdcb]] DEBUG org.apache.kafka.clients.NetworkClient
- [Consumer clientId=consumer-2, groupId=spark-kafka-source-8ce7f26f-e342-4b0d-85f1-a9f641b79629-1052905425-driver-0]
*Completed connection to node -1. Fetching API versions.*
>  11:46:18.061 [stream execution thread for [id = e393ea37-8009-4ce0-b996-94f767994fb8,
runId = bc15eb7d-876d-4e01-8ee5-22205ec7fdcb]] DEBUG org.apache.kafka.clients.NetworkClient
- [Consumer clientId=consumer-2, groupId=spark-kafka-source-8ce7f26f-e342-4b0d-85f1-a9f641b79629-1052905425-driver-0]
*Initiating API versions fetch from node -1.*
>  11:46:18.452 [stream execution thread for [id = e393ea37-8009-4ce0-b996-94f767994fb8,
runId = bc15eb7d-876d-4e01-8ee5-22205ec7fdcb]] DEBUG org.apache.kafka.common.network.Selector
- [Consumer clientId=consumer-2, groupId=spark-kafka-source-8ce7f26f-e342-4b0d-85f1-a9f641b79629-1052905425-driver-0]
Connection with *kafka-muhammad-45e0.aivencloud.com/18.203.67.147 disconnected*
>  *java.io.EOFException: null*
>  at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:119)
>  at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:335)
>  at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:296)
>  
>  
> I might be wrong, but this is the best option I thought to open an issue. 



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

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org


Mime
View raw message