51zero / 51zero/eel-sdk

Kafka Avro Schema Option

Open
#159 0 comments 0 reactions 0 assignees View on GitHub
enhancement help wanted priority
Dominant language
Scala
Stars
147
Forks
32
PR merge metrics
No merged PRs in 30d

Description

It would be great if it would be possible to provide the existing avro schema (from url or local path) option while reading Kafka Avro stream.

Currently running the following code produces the error below

KafkaSource(KafkaSourceConfig("localhost:12345", "consumer"), Set("topic1"), AvroKafkaDeserializer)

Exception in thread "main" java.io.IOException: Not a data file.
at org.apache.avro.file.DataFileStream.initialize(DataFileStream.java:105)
at org.apache.avro.file.DataFileReader.(DataFileReader.java:97)
at io.eels.component.kafka.AvroKafkaDeserializer$.apply(avro.scala:17)
at io.eels.component.kafka.KafkaSource.schema(KafkaSource.scala:36)
at io.eels.FrameSource.schema$lzycompute(Source.scala:29)
at io.eels.FrameSource.schema(Source.scala:29)
at io.eels.plan.SinkPlan$.apply(SinkPlan.scala:17)
at io.eels.Frame$class.to(Frame.scala:362)
at io.eels.FrameSource.to(Source.scala:23)

Thank you.
Roman.

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.