Ecosyste.ms: Repos
An open API service providing repository metadata for many open source software ecosystems.
GitHub / skalskibukowa / Project-Kafka-Flink
Project to practice Python / Kafka / Flink
JSON API: https://repos.ecosyste.ms/api/v1/hosts/GitHub/repositories/skalskibukowa%2FProject-Kafka-Flink
Stars: 0
Forks: 0
Open Issues: 0
License: None
Language: Shell
Repo Size: 17.6 KB
Dependencies:
37
Created: 4 months ago
Updated: 4 months ago
Last pushed: 4 months ago
Last synced: 4 months ago
Topics: bash, big-data, data-engineering, docker, flink-stream-processing, kafka-streams, postgresql, python3
Files
Loading...
Readme
Loading...
Dependencies
docker-compose.yml
docker
- confluentinc/cp-kafka latest
- confluentinc/cp-zookeeper latest
- flink-processor latest
- kafka-producer latest
flink-processor/Dockerfile
docker
- openjdk 8u151-jdk-alpine3.7 build
kafka-producer/Dockerfile
docker
- python 3.8-slim build
postgres/Dockerfile
docker
- postgres latest build
flink-processor/pom.xml
maven
- com.fasterxml.jackson.core:jackson-annotations 2.13.4
- com.fasterxml.jackson.core:jackson-databind 2.13.4
- com.fasterxml.jackson.datatype:jackson-datatype-jsr310 2.13.4
- org.apache.flink:flink-clients 1.16.0
- org.apache.flink:flink-connector-files 1.16.0
- org.apache.flink:flink-connector-jdbc 1.16.0
- org.apache.flink:flink-connector-kafka 1.16.0
- org.apache.flink:flink-csv 1.16.0
- org.apache.flink:flink-json 1.16.0
- org.apache.flink:flink-runtime 1.16.0
- org.apache.flink:flink-streaming-java 1.16.0
- org.apache.flink:flink-table 1.16.0
- org.apache.flink:flink-table-api-java 1.16.0
- org.apache.flink:flink-table-api-java-bridge 1.16.0
- org.apache.flink:flink-table-planner_2.12 1.16.0
- org.apache.kafka:kafka-clients 3.2.0
- org.apache.logging.log4j:log4j-api 2.17.2
- org.apache.logging.log4j:log4j-core 2.17.2
- org.apache.logging.log4j:log4j-slf4j-impl 2.17.2
- org.postgresql:postgresql 42.5.0
- com.github.javafaker:javafaker 1.0.2 test
- net.mguenther.kafka:kafka-junit 3.2.0 test
- org.apache.flink:flink-runtime-web 1.16.0 test
- org.apache.flink:flink-test-utils 1.16.0 test
- org.junit.jupiter:junit-jupiter-api 5.8.2 test
- org.junit.jupiter:junit-jupiter-engine 5.8.2 test
- Faker ==15.1.3
- aiokafka ==0.7.2
- kafka-python ==2.0.2
- schedule ==1.1.0