#

kafka

Here are 4,519 public repositories matching this topic...

apache / kafka

Star

Mirror of Apache Kafka

Updated Sep 27, 2020
Java

aalansehaiyang / technology-talk

Star

汇总java生态圈常用技术框架、开源中间件，系统架构、数据库、大公司架构案例、常用三方类库、项目管理、线上问题排查、个人成长、思考等知识

git java kafka spark spring es6 hbase springboot dubbo mycat

Updated Jun 29, 2020

yahoo / CMAK

Star

CMAK is a tool for managing Apache Kafka clusters

scala kafka big-data cluster-management

Updated Sep 9, 2020
Scala

flink-learning

zhisheng17 / flink-learning

Star

flink learning blog. http://www.flink-learning.com 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

mysql redis elasticsearch streaming kafka spark influxdb rabbitmq clickhouse hbase stream-processing opentsdb loki flink rocketmq

Updated Aug 11, 2020
Java

heibaiying / BigData-Notes

Star

大数据入门指南 ⭐

phoenix scala kafka big-data spark yarn hive hadoop storm bigdata hbase zookeeper hdfs mapreduce flume azkaban sqoop

Updated Sep 14, 2020
Java

YunaiV / SpringBoot-Labs

Star

一个涵盖六个专栏：Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖，右上角来个 Star，感恩 1024

kafka spring-boot rabbitmq spring-cloud activemq dubbo rocketmq spring-cloud-alibaba

Updated Sep 18, 2020
Java

thingsboard

thingsboard / thingsboard

Star

Open-source IoT Platform - Device management, data collection, processing and visualization.

visualization platform mqtt iot coap middleware kafka akka spark dashboard netty websockets grpc widgets iot-platform smart-farm fleet-tracking thingsboard iot-analytics

Updated Sep 27, 2020
Java

Shopify / sarama

Star

Sarama is a Go library for Apache Kafka 0.8, and up.

go kafka kafka-client

Updated Sep 24, 2020
Go

edenhill / librdkafka

Star

The Apache Kafka C/C++ library

c c-plus-plus kafka high-performance consumer kafka-consumer apache-kafka librdkafka kafka-producer

Updated Sep 27, 2020
C

dotnetcore / CAP

Star

Distributed transaction solution in micro-service base on eventually consistency, also an eventbus with Outbox pattern

kafka microservice rabbitmq service-bus message-bus event-bus distributed-transactions outbox

Updated Sep 25, 2020
C#

PipelineAI / pipeline

Star

PipelineAI Kubeflow Distribution

docker kubernetes redis machine-learning airflow kafka spark cassandra neural-network tensorflow gpu scikit-learn keras pytorch artificial-intelligence kubeflow tfx pipelineai

Updated Apr 24, 2020
Jsonnet

dpkp / kafka-python

Star

Python client for Apache Kafka

Updated Sep 23, 2020
Python

travisjeffery / jocko

Star

Kafka implemented in Golang with built-in coordination (No ZK dep, single binary install, Cloud Native)

go distributed-systems streaming kafka queue messaging

Updated Sep 16, 2020
Go

debezium / debezium

Star

Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.

database kafka kafka-connect apache-kafka kafka-producer cdc change-data-capture debezium event-streaming

Updated Sep 26, 2020
Java

confluentinc / ksql

Star

Open

KSQLDB fails to start if ssl.keystore.type=pkcs12 instead of ssl.keystore.type=PKCS12

JumaX commented Aug 20, 2020

Describe the bug
A clear and concise description of what the bug is.

KSQLDB fails to start if ssl.keystore.type=pkcs12 instead of ssl.keystore.type=PKCS12

To Reproduce
Steps to reproduce the behavior, include:

The version of KSQL.
Sample source data.
Any SQL statements you ran

Latest version of KSQLDB with Java 11 and FIPS support enabled.

Expected behavior
A

Read more

bug fix-it-week good first issue

Open

Support HEX Literals

Open

Support Comparisons on complex types

3

Find more good first issues →

2227324689 / gpmall

Star

【咕泡学院实战项目】-基于SpringBoot+Dubbo构建的电商平台-微服务架构、商城、电商、微服务、高并发、kafka、Elasticsearch

java elasticsearch kafka elk zookeeper sentinel springboot dubbo canal nacos springcloud-alibaba

Updated Sep 10, 2020
Java

nytimes / gizmo

Star

A Microservice Toolkit from The New York Times

go kafka sqs pubsub sns http-server gizmo googlecloud google-pubsub

Updated Sep 25, 2020
Go

fanliang11 / surging

Star

Surging is a micro-service engine that provides a lightweight, high-performance, modular RPC request pipeline. The service engine supports http, TCP, WS,Grpc, Mqtt, UDP, and DNS protocols. It uses ZooKeeper and Consul as a registry, and integrates it. Hash, random, polling, Fair Polling as a load balancing algorithm, built-in service governance to ensure reliable RPC communication, the engine contains Diagnostic, link tracking for protocol and middleware calls, and integration SkyWalking Distributed APM

Updated Aug 9, 2020
C#

segmentio / kafka-go

Star

Kafka library in Go

go segment golang kafka

Updated Sep 26, 2020
Go

wangzhiwubigdata / God-Of-BigData

Star

大数据面试题，大数据成神之路开启...Flink/Spark/Hadoop/Hbase/Hive...

kafka spark hive hadoop bigdata hbase zookeeper hdfs flume flink azkaban

Updated Sep 23, 2020

benthos

Jeffail / benthos

Star

A stream processor for mundane tasks written in Go

go golang kafka cqrs etl rabbitmq amqp logs message-bus event-sourcing nats stream-processing message-queue streaming-data stream-processor etl-pipeline

Updated Sep 27, 2020
Go

watermill

ThreeDotsLabs / watermill

Star

Open

Middleware per handler

2

roblaszczak commented Sep 16, 2019

Currently, you are not able to use middleware per handler in "clean way" (you can still manually wrap the handler function, or have separated router).

It would be nice to be able to add middleware per handler.

As a good reference point, you can use chi router: https://github.com/go-chi/chi

Read more

S enhancement good first issue help wanted

Open

Replace kafka-console-consumer with Mill in examples

Open

Cross-languages example

5

Find more good first issues →

qunarcorp / qmq

Star

Open

Prometheus能提供图片吗？

8

njkfei commented Jan 24, 2019

我看到可以通过Prometheus搭建监控环境，如果有图文，更容易理解．

Read more

good first issue

php-enqueue / enqueue-dev

Star

Message Queue, Job Queue, Broadcasting, WebSockets packages for PHP, Symfony, Laravel, Magento. DEVELOPMENT REPOSITORY - provided by Forma-Pro

redis symfony kafka rabbitmq amqp beanstalkd message-bus sns message-queue gearman stomp job-queue wamp rabbitmq-client doctrine-dbal amazon-sqs message-passing wamp-client google-pubsub

Updated Sep 27, 2020
PHP

OryxProject / oryx

Star

Oryx 2: Lambda architecture on Apache Spark, Apache Kafka for real-time large scale machine learning

java machine-learning kafka apache-spark cloudera apache-kafka lambda-architecture oryx

Updated Sep 7, 2020
Java

confluentinc / confluent-kafka-dotnet

Star

Confluent's Apache Kafka .NET client

c-sharp kafka dotnet nuget confluent kafka-client kafka-clients

Updated Sep 17, 2020
C#

pinterest / secor

Star

Secor is a service implementing Kafka log persistence

kafka

Updated Sep 25, 2020
Java

materialize

MaterializeInc / materialize

Star

The Streaming SQL Database powered by Timely Dataflow

rust distributed-systems streaming sql database kafka

Updated Sep 26, 2020
Rust

confluentinc / kafka-rest

Star

Confluent REST Proxy for Kafka

kafka schema-registry rest-api confluent kafka-rest-proxy

Updated Sep 26, 2020
Java

akhq

tchiotludo / akhq

Star

Kafka GUI for Apache Kafka to manage topics, topics data, consumers group, schema registry, connect and more...

java gui kafka kafka-utils kafka-tools kafka-ui kafkahq

Updated Sep 25, 2020
Java

Improve this page

Add a description, image, and links to the kafka topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the kafka topic, visit your repo's landing page and select "manage topics."

You can’t perform that action at this time.