Example project to show how to use Kafka from Spark Streaming with the Confluent schema registry
☆11Aug 17, 2016Updated 9 years ago
Alternatives and similar repositories for kafka-spark-avro-example
Users that are interested in kafka-spark-avro-example are comparing it to the libraries listed below. We may earn a commission when you buy through links labeled 'Ad' on this page.
Sorting:
- Spark 3.0.0 Structured Streaming Kafka Avro Demo☆15Apr 21, 2023Updated 2 years ago
- Code for processing AVRO data in Spark Streaming + Kafka (DirectKafka approach with custom offset management in zookeeper)☆29Sep 9, 2016Updated 9 years ago
- ☆48Feb 4, 2018Updated 8 years ago
- a sample spring boot kafka app using kafka and the avro schema registry☆16May 31, 2018Updated 7 years ago
- Golang log package extension. Automates logging routine: split files, archive, etc.☆11Nov 27, 2017Updated 8 years ago
- Deploy open-source AI quickly and easily - Bonus Offer • AdRunpod Hub is built for open source. One-click deployment and autoscaling endpoints without provisioning your own infrastructure.
- Display output of scripts in the macOS status bar☆15Feb 21, 2025Updated last year
- ☆10Apr 5, 2023Updated 3 years ago
- Spark UDFs to deserialize Avro messages with schemas stored in Schema Registry.☆20Jan 11, 2018Updated 8 years ago
- Optiq Adapter for JavaBean☆14Aug 6, 2014Updated 11 years ago
- The purpose of this tiny project is to put things together with the know how that i learned from the course big data expert from formacio…☆64Sep 11, 2018Updated 7 years ago
- Monitoring Traffinal monitoring signal using Apache Flink☆11Oct 25, 2016Updated 9 years ago
- crawling pinterest☆28Jan 18, 2023Updated 3 years ago
- Small, lightweight Java library to enable Domain Events (per Eric Evans, DDD) using an internal queue and asynchronous processing within …☆48Jun 26, 2020Updated 5 years ago
- 基于react-native 0.4.4 开发的IT资讯、程序员专属app，IT喵喵~☆11Jul 8, 2017Updated 8 years ago
- GPUs on demand by Runpod - Special Offer Available • AdRun AI, ML, and HPC workloads on powerful cloud GPUs—without limits or wasted spend. Deploy GPUs in under a minute and pay by the second.
- An Apache Flume Sink implementation to publish data to Apache pulsar☆21Oct 5, 2022Updated 3 years ago
- Create a C++ function definition from a declaration☆14Nov 7, 2023Updated 2 years ago
- suricata IDS的规则，测试在用的，部分自写的规则视情况放出。☆18Apr 16, 2019Updated 6 years ago
- wapman koa2后台管理 PC+移动端☆10Sep 27, 2021Updated 4 years ago
- NetBeans IDE plugin for Stapler web framework.☆23Mar 16, 2023Updated 3 years ago
- ☆31Sep 22, 2017Updated 8 years ago
- Example Scala blog application using event sourcing, memory image, and the Play! 2.0 framework.☆81Nov 2, 2016Updated 9 years ago
- ☆26Aug 31, 2020Updated 5 years ago
- encoding format, library, and utilities for passive DNS data☆27Mar 29, 2024Updated 2 years ago
- Wordpress hosting with auto-scaling - Free Trial • AdFully Managed hosting for WordPress and WooCommerce businesses that need reliable, auto-scalable performance. Cloudways SafeUpdates now available.
- Scrapy 新浪新闻爬虫☆12Aug 26, 2019Updated 6 years ago
- The demo project of the HTN planning plugin for Unreal Engine 4/5☆19Jan 16, 2026Updated 2 months ago
- The Domain Name System is a fundamental component of the internet since it maps the easy-to-remember domain names to IP addresses. Theref…☆16Oct 2, 2020Updated 5 years ago
- Docker Image for kafka-connect☆18Jun 30, 2018Updated 7 years ago
- Custom kernel with activated all Exynos 7580 Octa cores for Samsung Galaxy A3 (2016)☆12Jun 27, 2017Updated 8 years ago
- Pulsar IO Kafka Connector☆23Mar 17, 2023Updated 3 years ago
- SamzaSQL: Streaming SQL implementation on top of Apache Samza and Apache Kafka☆29Jun 8, 2016Updated 9 years ago
- spring-boot-batch-demo☆13Aug 30, 2020Updated 5 years ago
- A tool for translating Scala source code into readable and maintainable Java code☆13Jan 3, 2026Updated 3 months ago
- GPUs on demand by Runpod - Special Offer Available • AdRun AI, ML, and HPC workloads on powerful cloud GPUs—without limits or wasted spend. Deploy GPUs in under a minute and pay by the second.
- ☆14Jul 18, 2020Updated 5 years ago
- ServiceFramework 示例项目☆10Apr 2, 2016Updated 10 years ago
- Angstrom repository with updated layers file☆11Jul 9, 2021Updated 4 years ago
- npm801☆15Jun 29, 2018Updated 7 years ago
- Full web application built upon Play 2.0 and ReactiveMongo☆172Feb 21, 2016Updated 10 years ago
- An implementation of CQRS using scalaz for functional domain models and Akka for event sourcing☆107Mar 17, 2012Updated 14 years ago
- Passive DNS Common Output Format☆37Aug 30, 2024Updated last year