luigiselmi / flink-kafka-consumerView external linksLinks
A consumer of a Kafka topic based on Flink
☆12Oct 5, 2022Updated 3 years ago
Alternatives and similar repositories for flink-kafka-consumer
Users that are interested in flink-kafka-consumer are comparing it to the libraries listed below
Sorting:
- Realtime feedback of Akka Stream processing via WebSockets☆16Dec 9, 2019Updated 6 years ago
- springboot+mybatis+tkmybatis+druid+多数据源配置示例☆18Nov 22, 2018Updated 7 years ago
- Simple example for reading and writing into Kafka☆55Oct 19, 2020Updated 5 years ago
- A collection of runnable and self-contained examples inspired by various akka-streams (pekko-streams), Alpakka (Pekko connectors) and akk…☆34Nov 28, 2025Updated 2 months ago
- Getting Started Samples for using MQTT with Solace Message Routers.☆28Apr 20, 2022Updated 3 years ago
- Akka Cookbook, published by Packt☆32Jan 30, 2023Updated 3 years ago
- MVC fastify decorator Dependency injection Inversion of Control Typescript☆11Jan 5, 2023Updated 3 years ago
- A stateful distributed balance service with persistent entities via sharding in persistence mode☆13Oct 26, 2018Updated 7 years ago
- openEHR Clinical modelling tooling setup☆10Jun 24, 2018Updated 7 years ago
- hadoop中Map/Reduce使用示例，输入(DBInputFormat),输出(DBOutputFormat)为MySql数据库表、日志分析Grep、单词排序Sort...对HBase的基本操作，增、删、查、改，使用Map/Reduce批量导入数据到HBase表中..…☆14Apr 6, 2013Updated 12 years ago
- Kubenetes with SpringBoot demo☆10Feb 20, 2019Updated 6 years ago
- Hypothesis testing (Parametric/Non-Parametric)☆11Oct 8, 2019Updated 6 years ago
- Materials related to testing different ways/drivers to access databases☆40Jul 27, 2022Updated 3 years ago
- 本项目主要用于搭建一个基于docker的实时监控系统，涉及的大数据相关组件有Filebeat，Kafka，Zookeeper，Flink，后端主要使用了SpringBoot进行开发，数据库使用了Redis做缓存，前端用了Vue框架，通过Ant Design组件库和Echar…☆42Jan 5, 2023Updated 3 years ago
- jt808服务端☆11Dec 21, 2021Updated 4 years ago
- An AI agent to create short stories, using Gemini and Imagen for illustrations. The project is developed in Java 21 with LangChain4j, and…☆10Sep 4, 2025Updated 5 months ago
- Hadoop, Hive, Spark, Zeppelin and Livy: all in one Docker-compose file.☆11Apr 30, 2022Updated 3 years ago
- A Basic Flink Application Consuming & Aggregating Kafka Messages☆10Nov 8, 2019Updated 6 years ago
- Idiomatic and reactive Scala client for Aerospike database☆10Dec 28, 2024Updated last year
- thingsboard widget☆12Aug 8, 2022Updated 3 years ago
- bootstrap template for akka microservices with an graphql endpoint☆11Aug 13, 2017Updated 8 years ago
- Master postgreSQL with vagrant☆13Apr 18, 2021Updated 4 years ago
- 用 VC++实现 C/S 模式下的远程控制，包含鼠标和键盘响应以及屏幕截图的传输与解压。☆12Aug 23, 2014Updated 11 years ago
- 🚀 Material-UI based Audio Player☆10Dec 2, 2022Updated 3 years ago
- Example Lagom.js application☆10Jul 10, 2021Updated 4 years ago
- 可实现异构应用系统间的数据转换、信息传递和业务的编排与重组☆12Nov 16, 2022Updated 3 years ago
- An example of how the LIME algorithm can be used to provide real-world insight into the decision processes of a 'black-box' machine learn…☆15Feb 19, 2019Updated 6 years ago
- ☆12Oct 15, 2022Updated 3 years ago
- An extensible home automation framework☆70Sep 30, 2015Updated 10 years ago
- 把知乎的REST API改造成GraphQL API示例☆35Mar 4, 2023Updated 2 years ago
- Cassandra pagination example with spring boot.☆11Jul 29, 2021Updated 4 years ago
- Cloudera CDP SDK for Java☆15Jan 7, 2026Updated last month
- POC for all the stack of big data (kafka, spark, cassandra, hdfs, docker, springboot)☆12Dec 16, 2022Updated 3 years ago
- FIWARE 305: Real-time Processing of Context Data using Apache Flink☆11Jan 27, 2026Updated 2 weeks ago
- 对etcd中实现的raft算法进行注释☆11Jun 6, 2017Updated 8 years ago
- A simple project demonstrates the integration of Spring boot, ActiveMQ, Camel and STOMP☆11Aug 31, 2016Updated 9 years ago
- simple teamviewer☆11Jul 9, 2019Updated 6 years ago
- Discussion for Stan for economists☆10Mar 29, 2016Updated 9 years ago
- EVM-compatible Cosmos Chain for scalable and interoperable DApps and smart contracts, integrating Ethereum's robust features with Cosmos'…☆12Dec 22, 2023Updated 2 years ago