errors met when Using sparkstreaming with token to consume
- Dominant language
- Java
- Stars
- 15.3k
- Forks
- 3.8k
- Avg merge
- 1d 22h
- Merged PRs (30d)
- 142
Description
when I consume topic by sparkstreming with token ,it meet errors. The code and error is as follows:
val pulsarReceiver = new SparkStreamingPulsarReceiver(serviceUrl,pulsarConf,AuthenticationFactory.token(pulsarToken))
https://static.dingtalk.com/media/lALPGojJ7356Q-jNAo7NCmo_2666_654.png_720x720q90g.jpg?bizType=im
Does pulsar support Using sparkstreaming with token to consume? What should I do?
I need help,thanks!
Contributor guide
Research direction
Start by reproducing the provided Spark Streaming consumer example with AuthenticationFactory.token and inspect the linked error image. Trace how token authentication is passed into SparkStreamingPulsarReceiver and verify whether token-based consumption works or requires documented configuration; done means the behavior is explained and a supported fix or limitation is recorded.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java, spark
- Domain
- authentication, stream-processing
- Issue type
- Bug
- Difficulty
- 3/5
- Estimated time
- 1-2 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 25/100