Discover bakdata/common-kafka-streams-demo Open Source project

Stars
9
Rank 1,939,727 (Top 39 %)
Language
Java
License
MIT License
Created over 4 years ago
Updated almost 2 years ago

bakdata

There are no reviews yet. Be the first to send feedback to the community and the maintainers!

Demo Kafka Streaming NLP pipeline for the blogpost "Continuous NLP Pipelines with Python, Java, and Apache Kafka"

aws-lambda-r-runtime

Serverless execution of R code on AWS Lambda

Python

143

fluent-kafka-streams-tests

Fluent Kafka Streams Test with Java

Java

kafka-large-message-serde

A Kafka Serde that reads and writes records from and to Blob storage (S3, Azure, Google) transparently.

Java

streams-explorer

Explore Apache Kafka data pipelines in Kubernetes.

Python

conquery

Visual, interactive queries against big databases

Java

streams-bootstrap

Utility functions and base classes for Kafka Streams applications

Java

kafka-key-value-store

Queryable Kafka Topics with Kafka Streams.

Java

dedupe

Java DSL for (online) deduplication

Java

google-airflow-premier-league

Data Warehousing Made Easy with Google BigQuery and Apache Airflow

Shell

kafka-error-handling

A library for error handling in Kafka Streams.

Java

conversational-search-bot

Conversational search bot for book and movie recommendations

Jupyter Notebook

quick

The Fastest Way to Create Live Data Products

Java

kpops

Deploy Kafka pipelines to Kubernetes

Python

kafka-profile-store-demo

A Kafka Streams application that creates a queryable profile store

Java

citus-k8s-membership-manager

A manager for connecting Citus worker nodes with the Citus master node.

Python

rebalancing-demo

Repository that showcases problems with Kafka rebalancing and explains how to fix them. Please visit our blog article to learn what Kafka rebalancing is, what can cause problems, and how to solve them. https://medium.com/bakdata/solving-my-weird-kafka-rebalancing-problems-c05e99535435

Java

kserve-client

A Java client for KServe inference services

Java

ignite-hbase

Adapter to use ignite as hbase cache

Java

faust-bootstrap

Utility functions and base classes for Faust applications

Python

faust-avro-serializer

An improved version of https://github.com/marcosschroh/python-schema-registry-client/

Python

kafka-brute-force-serde

A Kafka SerDe to deserialize messages of an unknown serialization format

Java

kafka-streams-kserve-demo

A demo to accompany our blogpost "Scalable Machine Learning with Kafka Streams and KServe"

Java

ci-templates

Collection of reusable workflows and composite actions for Github

Shell

s3-backed-serde-demo

Demo of S3-backed Kafka Streams SerDe

Java

connection_plugin

Templating for Airflow connections

Python

kafka-connect-resetter

An application to reset the state of Kafka Connect connectors

Java

sub-topologies-demo

Demo application for the Blogpost "Optimizing Kafka Streams Topologies running on Kubernetes"

Java

generic-avro-reflect

Allows generic types to be serialized in avro

Java

nginx-kafka-request-routing

Scaling Requests to Queryable Apache Kafka Topics with nginx

Lua

seq2

This library is a extension to the great jOOλ library (https://github.com/jOOQ/jOOL)

Java

faust-large-message-serializer

A Faust Serializer that reads and writes records from and to S3 or Azure Blob Storage transparently.

Python

kafka-dead-letter-analyzer

A Kafka Streams application that analyzes dead letters in your Kafka cluster

Java

hpi-ii-project-2022

Repository containing the code for the assignment of the Information Integration course in SoSe 2022

Python

kafka-connect-plugins

A collection Kafka Connect plugins

Java

cqapi

Python

bakdata-code-styles

The default code styles + tools to setup for the major IDEs

Shell

gradle-plugins

Convience plugins that orchestrate and preconfigure other plugins for release management or code quality.

Kotlin

gradle-avro-dependency-plugin

A Gradle plugin that lets you compile Apache Avro schemas to Java classes and supports dependencies

Kotlin

pipeline-atm-fraud

Demo pipeline for ATM fraud detection using streams-bootstrap

Java

rclone-helm-chart

Helm chart for deploying an rclone CronJob

Mustache

bakdata/common-kafka-streams-demo

bakdata

Reviews

Repository Details

More Repositories