GitHub user liu-zhaokun opened a pull request:
https://github.com/apache/spark/pull/19887
[SPARK-21168] KafkaRDD should always set kafka clientId.
There are no a number of other places that a client ID should be set,and I
think we should use consumer.clientId in the clientId method,because the fetch
request will be used by the same consumer behind.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/liu-zhaokun/spark master1205
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/spark/pull/19887.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #19887
----
commit 5071789d3ee0a99d832b8edada23bbec51abf15e
Author: liuzhaokun <[email protected]>
Date: 2017-12-05T01:30:27Z
[SPARK-21168] KafkaRDD should always set kafka clientId.
----
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
