Ecosyste.ms: Repos
An open API service providing repository metadata for many open source software ecosystems.
GitHub / mojeskamlapure / streaming-application-examples
An ETL project that consumes data from distributed message queue such as kafka and transform the data using flink stand alone job which in-turn stores data to the nosql database such as Cassandra distributed database.
Stars: 0
Forks: 0
Open Issues: 0
License: apache-2.0
Language: Java
Repo Size: 269 KB
Dependencies:
25
Created: about 2 years ago
Updated: almost 2 years ago
Last pushed: almost 2 years ago
Last synced: over 1 year ago
Topics: bash-script, cassandra-database, dockerfile, flink-stream-processing, java, jmc, jmeter, kafka, kafka-consumer, kafka-producer, kubernetes, shell-script, spark-sql, spring-boot-microservice, spring-kafka
Files
Dependencies
- com.learn:DataModel 0.0.1-SNAPSHOT
- org.apache.flink:flink-connector-cassandra_2.12 1.11.1
- org.apache.flink:flink-connector-kafka-0.11_2.11 1.11.1
- org.apache.flink:flink-java 1.11.1
- org.apache.flink:flink-streaming-java_2.11 1.11.1
- org.apache.flink:flink-streaming-scala_2.11 1.11.1
- org.apache.logging.log4j:log4j-api 2.17.1
- org.apache.logging.log4j:log4j-core 2.17.1
- org.apache.logging.log4j:log4j-slf4j-impl 2.17.1
- com.datastax.spark:spark-cassandra-connector_2.12 3.0.0 provided
- org.apache.spark:spark-core_2.12 3.0.0 provided
- org.apache.spark:spark-sql_2.12 3.0.0 provided
- com.datastax.spark:spark-cassandra-connector-assembly_2.12 3.0.0
- com.thoughtworks.paranamer:paranamer 2.8
- joda-time:joda-time 2.9.4
- org.springframework.boot:spring-boot-starter-web
- org.springframework.boot:spring-boot-starter-test test