Demonstrates Flink Kafka connector
There are two modes of serializing the data. Compressed and non compressed. Lz4 compression is as of now supported.
Use FileDeserializationSchema as the deserializer schema for FlinkKafkaConsumer010.
-
Notifications
You must be signed in to change notification settings - Fork 0
sriramta/flink-kafka
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
About
No description, website, or topics provided.
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published