You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@spark.apache.org by "Apache Spark (JIRA)" <ji...@apache.org> on 2017/11/22 09:37:00 UTC

[jira] [Assigned] (SPARK-21168) KafkaRDD should always set kafka clientId.

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

Apache Spark reassigned SPARK-21168:
------------------------------------

    Assignee:     (was: Apache Spark)

> KafkaRDD should always set kafka clientId.
> ------------------------------------------
>
>                 Key: SPARK-21168
>                 URL: https://issues.apache.org/jira/browse/SPARK-21168
>             Project: Spark
>          Issue Type: Bug
>          Components: DStreams
>    Affects Versions: 2.0.2
>            Reporter: Xingxing Di
>            Priority: Trivial
>
> I found KafkaRDD not set kafka client.id in "fetchBatch" method (FetchRequestBuilder will set clientId to empty by default),  normally this will affect nothing, but in our case ,we use clientId at kafka server side, so we have to rebuild spark-streaming-kafka。



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

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