I was able to resolve the error. Initially I was giving custom name for
subscribe but was giving topic name at topics options.Giving the same name
at both places worked.
I am confused now with the difference of giving value for topic and
subsribe here. do you have any suggestions?
reader.option
Have you tried what the exception suggests?
If startingOffsets contains specific offsets, you must specify all
TopicPartitions.
BR,
G
On Tue, May 21, 2019 at 9:16 PM KhajaAsmath Mohammed <
mdkhajaasm...@gmail.com> wrote:
> Hi,
>
> I am getting below errror when running sample strreaming app. d
Hi,
I am getting below errror when running sample strreaming app. does anyone
have resolution for this?
JSON OFFSET {"test":{"0":0,"1":0,"2":0,"3":0,"4":0,"5":0}}
- Herreee
root
|-- key: string (nullable = true)
|-- value: string (nullable = true)
|-- topic: string (nullable = true)
|--
