You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@spark.apache.org by "Chandan (JIRA)" <ji...@apache.org> on 2018/10/15 08:55:00 UTC
[jira] [Created] (SPARK-25731) Spark Structured Streaming Support
for Kafka 2.0
Chandan created SPARK-25731:
-------------------------------
Summary: 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
[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)
--
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