bakdata/rebalancing-demo

Stars
10
Rank 1,807,489 (Top 36 %)
Language
Java
License
MIT License
Created over 4 years ago
Updated over 4 years ago

bakdata/rebalancing-demo

bakdata

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

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

aws-lambda-r-runtime

Serverless execution of R code on AWS Lambda

fluent-kafka-streams-tests

Fluent Kafka Streams Test with Java

kafka-large-message-serde

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

streams-explorer

Explore Apache Kafka data pipelines in Kubernetes.

conquery

Visual, interactive queries against big databases

streams-bootstrap

Utility functions and base classes for Kafka Streams applications

kafka-key-value-store

Queryable Kafka Topics with Kafka Streams.

dedupe

Java DSL for (online) deduplication

google-airflow-premier-league

Data Warehousing Made Easy with Google BigQuery and Apache Airflow

kafka-error-handling

A library for error handling in Kafka Streams.

conversational-search-bot

Conversational search bot for book and movie recommendations

Jupyter Notebook

quick

The Fastest Way to Create Live Data Products

kpops

Deploy Kafka pipelines to Kubernetes

kafka-profile-store-demo

A Kafka Streams application that creates a queryable profile store

citus-k8s-membership-manager

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

common-kafka-streams-demo

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

kserve-client

A Java client for KServe inference services

ignite-hbase

Adapter to use ignite as hbase cache

faust-bootstrap

Utility functions and base classes for Faust applications

faust-avro-serializer

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

kafka-brute-force-serde

A Kafka SerDe to deserialize messages of an unknown serialization format

kafka-streams-kserve-demo

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

ci-templates

Collection of reusable workflows and composite actions for Github

s3-backed-serde-demo

Demo of S3-backed Kafka Streams SerDe

connection_plugin

Templating for Airflow connections

kafka-connect-resetter

An application to reset the state of Kafka Connect connectors

sub-topologies-demo

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

generic-avro-reflect

Allows generic types to be serialized in avro

nginx-kafka-request-routing

Scaling Requests to Queryable Apache Kafka Topics with nginx

seq2

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

faust-large-message-serializer

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

kafka-dead-letter-analyzer

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

hpi-ii-project-2022

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

kafka-connect-plugins

A collection Kafka Connect plugins

cqapi

bakdata-code-styles

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

gradle-plugins

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

gradle-avro-dependency-plugin

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

pipeline-atm-fraud

Demo pipeline for ATM fraud detection using streams-bootstrap

rclone-helm-chart

Helm chart for deploying an rclone CronJob