Awesome Open Source

Programming Languages

Search results for golang kafka

179 search results found

Dolphinbeat ⭐ 153

A server that pulls and parses MySQL binlog, pushs change data into different sinks like Kafka.

Go Kafka Example ⭐ 149

Golang Kafka consumer and producer example

Openmock ⭐ 149

Mock all the services. Intuitive YAML DSL for HTTP, gRPC, Kafka, and AMQP mocks.

Istio Micro ⭐ 148

istio 微服务示例代码 grpc+protobuf+echo+websocket+mysql+redis+kafka+doc

Flow Pipeline ⭐ 140

A set of tools and examples to run a flow-pipeline (sFlow, NetFlow)

Syslog Gollector ⭐ 133

Syslog Collector written in Go, streams to Kafka 0.8

Kafka Konsumer ⭐ 130

Easy implementation of kafka consumer with built-in exception manager (kafka-cronsumer)

Producer and Consumer for Kafka in Go

Golang 小视频教程，零散时间学习 Golang

A kafka command line browser

Flowbro ⭐ 118

Real-time flowchart visualisation for Kafka-based distributed systems.

Schema Registry ⭐ 116

A CLI and Go client for Kafka Schema Registry. This repository is deprecated and no longer maintained.

Xk6 Kafka ⭐ 116

k6 extension to load test Apache Kafka with support for various serialization formats, SASL, TLS, compression, Schema Registry client and beyond

Studyguide ⭐ 113

Rochefort ⭐ 111

poor man's kafka (plus in-place mutations and search)

Event Driven Example ⭐ 111

An example Event-Driven application in Go built with Watermill library.

Golang Cookbook ⭐ 110

golang基础知识及实现，偏重于数据结构。另外包含web开源项目(中间件)的日常使用

Nats Kafka ⭐ 109

NATS to Kafka Bridging

Hyperledger Fabric Kubernetes ⭐ 108

Blockchain Solution with Hyperledger Fabric + Hyperledger Explorer on Kubernetes

Go Interview ⭐ 107

golang 面试总结

JR: streaming quality random data from the command line

Terraform Provider Kafka Connect ⭐ 104

Terraform provider for managing Apache Kafka Connect

imgo is a push server written by golang based on goim

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

Gopassivedns ⭐ 99

PassiveDNS in Go

This repository contains code which I am using to learn Go. Hoping it can be useful to someone, I've uploaded them here in github.

A full ecosystem that is built around kafka powered by golang

Kafta is a command line for managing Kafka clusters

Distributed API Gateway

Kafkactl ⭐ 82

CLI for Apache Kafka Management -

Herman基于Gin，Casbin，Kafka，Mysql，Redis，Zap，Cobra，Gro

Logging/Metrics Daemon: Logstash Formatted write to Elasticsearch with Fluentd, Kafka, Monit inputs and Graphite, Elasticsearch outputs

Mysqltoall ⭐ 80

A Mysql data to file/elasticsearch/kafka/redis/redis-cluster/mongo and normal)/TiDB/postgresql with binlog tool.

Haproxy Rest ⭐ 79

REST interface for HAproxy written in GO

MySQL active-active replication solution.

以Kafka为存储介质，提供异步Http RPC的中间件

Sample project of using sarama

Go Consumergroup ⭐ 76

golang kafka consumer group

Generator Mitosis ⭐ 75

A micro-service infrastructure generator based on Yeoman/Chatbot, Kubernetes/Docker Swarm, Traefik, Ansible, Jenkins, Spark, Hadoop, Kafka, etc.

Kafka Elasticsearch Injector ⭐ 72

Golang app to read records from a set of kafka topics and write them to an elasticsearch cluster

Kafka Go Example ⭐ 71

kafka-go-example 以及系列教程

RabbitMQ to Kafka bridge

Tangseng ⭐ 69

Tangseng search engine including full text search and vector search base on golang. 基于go语言的搜索引擎，信息检索系统

Savetheworldwithgo ⭐ 69

Build systems with Go examples

Kafka Message Scheduler ⭐ 68

scheduler for kafka messages

Kafka Cronsumer ⭐ 68

Cron based Kafka exception consumer with the power of auto retry & concurrency

Sniffer Agent ⭐ 67

Sniffer MySQL package: capture TCP package, parsed with mysql protocol, optional you can send query info to Kafka. 抓取tcp包解析出mysql语句

Go Base Service ⭐ 64

This project allows developers to build services for exporting REST APIs. It makes it easy to connect to databases, cache, Kafka, S3, elasticsearch and authentication. Keep building !

Go Dcp Kafka ⭐ 64

The Go implementation of the Couchbase to Kafka with DCP.

Vsphere Graphite ⭐ 63

VMware vSphere stats to storage backends as graphite, influxdb, elasticsearch or prometheus

Pg2kafka ⭐ 63

Ship changes in Postgres 🐘 to Kafka 📖

Chanbroker ⭐ 60

ChanBroker, a Broker for goroutine, is simliar to kafka

Ksqldb Go ⭐ 59

A Golang client for ksqlDB

Ostraka is an open-source project that simplifies event synchronization in microservice architectures. It collects events from various sources and transforms them into Server-Sent Events (SSE) or email notifications for easy consumption in the user interface.

Connbeat ⭐ 56

Agent exposing connection-related information, based on the Elastic Beats framework

Event Gateway ⭐ 54

AsyncAPI Event Gateway

Kafka_zookeeper_exporter ⭐ 54

Prometheus exporter for Kafka cluster state stored in ZooKeeper

Making support for Apache Kafka in Go better

Watermill Kafka ⭐ 50

Kafka Pub/Sub for the Watermill project.

Goharvest ⭐ 50

Transactional outbox harvester for Postgres → Kafka, written in Go

Events Breakfast Demo ⭐ 50

Demo to go with https://eggybits.com/posts/events-first 🍳🥞

Kafka consumer lag monitor

Awesome Huzhi ⭐ 49

学习心得，笔记，资源汇总等

Etl Engine ⭐ 47

etl engine 轻量级跨平台流批一体ETL引擎数据抽取-转换-装载 ETL engine lightweight cross platform batch flow integration ETL engine data extraction transformation loading

Tipoca Stream ⭐ 44

Near real time cloud native data pipeline in AWS (CDC+Sink). Hosts code for RedshiftSink. RDS to RedshiftSink Pipeline with masking and reloading support.

Serverless Operator ⭐ 43

Main source repository for Openshift Serverless

Implementation of the NELI leader election protocol for Go and Kafka

Interoperable GRPC based publish/subscribe

Kaf Relay ⭐ 40

Replicate and sync kafka topics between clusters in realtime. Supports topic re-mapping, healthchecks, and hot failovers for high availability.

☁EventBus on Portable Pub/Sub Components☄

Asyncapi Codegen ⭐ 39

Generate Go client and server boilerplate from AsyncAPI specifications

Aiven Examples ⭐ 39

Aiven "getting started" code examples

Go Graphql Subscription Example ⭐ 38

☝️ go-graphql subscription over Kafka/Redis/NSQ example

Core Flogo activities, triggers and functions that are useful across the various event-driven action types.

Blueking Dbm ⭐ 37

DBM，数据库管理

Kafka Listeners ⭐ 37

Prometheus Kafka Consumer Group Exporter ⭐ 36

Prometheus exporter for Kafka consumer group information obtained through `kafka-consumer-groups.sh`.

Queue library wrapper for widely popular queues - RabitMQ, Kafka, NSQ, NATS

Distributedarchitectures ⭐ 36

Naiserator ⭐ 35

Naiserator creates a full set of Kubernetes application infrastructure based on a single application spec.

my tech blog, using markdown

Lenses Go ⭐ 34

Lenses.io CLI (command-line interface)

Terraform Provider Kafka ⭐ 33

Terraform provider for kafka

Grpc Kafkademo ⭐ 33

Use Consul to do service discovery, use gRPC +kafka to do message produce and consume. Use redis to store result.

Burrow_exporter ⭐ 33

A Prometheus Exporter for gathering Kafka consumer group info from Burrow

Dependency free drop-in replacement for Kafka written in Go.

Sandwich Daemon ⭐ 31

Sandwich Daemon is the middle man between discord and your microserviced bot. Handles gateway, state and provides a dashboard.

Redpanda Examples ⭐ 31

A collection of examples to demonstrate how to interact with Redpanda from various clients and languages.

CLI tool and Go client library for the Kafka Connect REST API

Books Recommendation ⭐ 31

程序员进阶书籍/视频，持续更新（Programmer Books）

Ksqldb Go ⭐ 31

ksqldb-go client

Kafka Offset Mgr ⭐ 30

Simple command line tool written in Go to view and change Kafka consumer offsets stored in Kafka.

A Kafka consumer coordination library for Go.

A fast massive push platform for APNs and FCM

Kafka_cluster_example ⭐ 30

🪲 kafka cluster example

Go Kafka Example ⭐ 30

An API and Worker using Kafka publish+subscribe written in Golang

Kafka Gateway ⭐ 29

🌊 Kafka Gateway (gRPC/protobuf + http/json)

Strimzi Canary ⭐ 29

方便可靠的异步任务处理系统

Golang netflow parsing with flexible storage backend.

Related Searches

Golang Command Line (8,308)

Golang Kubernetes (7,295)

Golang Server (4,285)

Golang Http (4,189)

Javascript Golang (3,372)

Java Kafka (3,237)

Golang Database (2,927)

Golang Json (2,652)

Golang Proxy (2,577)

Docker Golang (2,394)

101-179 of 179 search results

Privacy | About | Terms | Follow Us On Twitter

Copyright 2018-2024 Awesome Open Source. All rights reserved.