Hi All,
I am getting the below error while using Pyspark Structured Streaming from
Kafka Producer.
20/05/06 11:51:16 ERROR ReceiverTracker: Deregistered receiver for stream 0:
Error starting receiver 0 - kafka.common.InvalidConfigException: client.id
Python Kafka streamer is illegal, contains a character other than ASCII
alphanumerics, '.', '_' and '-'
I am using the below code to get the messages:
broker='vm105:2181'
topic='Hello-Kafka'
print 'broker topic is ',broker,topic
kvs = KafkaUtils.createStream(ssc, \
broker, \
"Python Kafka streamer",{topic:1})
And my Submit command is like below :-
spark-submit --jars spark-streaming-kafka-0-8-assembly_2.11-2.4.4.jar
test_kafka.py vm105:2181 Hello-Kafka
Can any one help me what am I missing. ?
Thanks,
Vijayant
________________________________
This e-mail message may contain confidential or proprietary information of
Mavenir Systems, Inc. or its affiliates and is intended solely for the use of
the intended recipient(s). If you are not the intended recipient of this
message, you are hereby notified that any review, use or distribution of this
information is absolutely prohibited and we request that you delete all copies
in your control and contact us by e-mailing to [email protected]. This
message contains the views of its author and may not necessarily reflect the
views of Mavenir Systems, Inc. or its affiliates, who employ systems to monitor
email messages, but make no representation that such messages are authorized,
secure, uncompromised, or free from computer viruses, malware, or other
defects. Thank You
