#

producer

Here are 111 public repositories matching this topic...

segmentio / kafka-go

Star

Kafka library in Go

go segment golang kafka consumer golang-library kafka-client producer golang-native

Updated Nov 23, 2020
Go

confluentinc / confluent-kafka-go

Star

Confluent's Apache Kafka Golang client

golang consumer confluent golang-library librdkafka kafka-client producer golang-bindings

Updated Nov 20, 2020
Go

qunarcorp / qmq

Star

Open

Prometheus能提供图片吗？

8

njkfei commented Jan 24, 2019

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

Read more

good first issue

authorjapps / zerocode

Star

Open

[Doc][Wiki]Assertion for various data types

4

authorjapps commented Aug 5, 2020

As a SDET
I want a documentation or Wiki page where the expected vs actual field matching is explained
So that I can use these in my test automation to test the server response payloads and headers
e.g. id=123 , id="123", isValid=true, isValid="true" etc

AC1:

Cover the following currently supported mechanisms with examples

$EQ
(int)
(float) or (decimal)
(boolean)

Read more

good first issue help wanted readme-doc

Open

Parameterized csvSource with body payload from reusable external JSON file

5

Open

ClassCastException Thrown when referring json file in request body with content type "multipart/form-data"

7

Find more good first issues →

Qihoo360 / qbusbridge

Star

The Apache Kafka Client SDK

python golang php kafka cplusplus consumer kafka-consumer kafka-producer producer kafkaclient kafkasdk kafkabridge

Updated Sep 8, 2020
C++

nodefluent / node-sinek

Star

Open

Ensure latest kafkajs settings are used

rob3000 commented Aug 14, 2020

based on: https://kafka.js.org/docs/configuration and tulios/kafkajs#298
We may not have the correct settings for the JSConsumer and JSProducer. This issue is to ensure we have them up to date after nodefluent/node-sinek#154 has been merged

Read more

enhancement good first issue

mre / kafka-influxdb

Sponsor Star

High performance Kafka consumer for InfluxDB. Supports collectd message formats.

performance logstash influxdb consumer kafka-consumer producer kafka-influxdb

Updated Nov 13, 2020
Python

a8m / kinesis-producer

Star

An aggregated records producer for Amazon Kinesis

go kinesis amazon-kinesis producer kpl kpl-aggregation kinesis-producer

Updated Mar 11, 2020
Go

davidmarquis / redisq

Star

RedisQ - Java implementation of a reliable Pub/Sub message queue based on Redis

java redis queue consumer producer reliable

Updated Sep 4, 2017
Java

hyeonsangjeon / youtube-dl-nas

Star

youtube download queue websocket server with login for private NAS.

python bootstrap docker youtube queue login async websocket thread youtube-dl publisher consumer login-system producer bottle subscribe nas

Updated Nov 13, 2020
Python

qianguozheng / go-workerpool

Star

Worker pool implementation

golang high-performance consumer producer worker-pool workpool workerpool

Updated Sep 13, 2018
Go

silviucpp / erlkaf

Star

Erlang kafka driver based on librdkafka

erlang kafka consumer librdkafka producer

Updated Nov 3, 2020
Erlang

robinjoseph08 / redisqueue

Star

redisqueue provides a producer and consumer of a queue that uses Redis streams

go redis golang streams consumer producer producer-consumer

Updated Oct 15, 2020
Go

sevennt / rocketmq

Star

RocketMQ client for go supportting producer and consumer.

go consumer producer rocketmq

Updated Jun 7, 2018
Go

authorjapps / hello-kafka-stream-testing

Star

The most simple way to test Kafka based applications or micro-services e.g. Read/Write during HBase/Hadoop or other Data Ingestion Pipe Lines

java testing docker json schema kafka rest stream integration avro topic proxy cluster consumer producer raw

Updated Oct 13, 2020
Java

qntfy / frizzle

Star

The magic message bus

golang kafka pipeline message-bus kinesis consumer stream-processing golang-library producer streaming-data

Updated Mar 21, 2019
Go

hands-on-tech / kafka-spark-flink-example

Star

Kafka streaming with Spark and Flink example

java docker kafka spark consumer producer flink kafka-streams

Updated Nov 1, 2018
Java

tolitius / grete

Star

kafka client with threads and a scheduler

kafka concurrency consumer thread-pool producer

Updated Nov 17, 2020
Clojure

suredone / qdone

Star

Command line job queue for SQS

cli console aws queue command-line amazon cloudwatch workers sqs listen consumer producer job-queue amazon-web-services enqueue jobs-qdone

Updated Jul 15, 2020
JavaScript

qntfy / frafka

Star

Frizzle for Apache Kafka

golang kafka pipeline message-bus consumer stream-processing golang-library producer streaming-data

Updated Sep 18, 2020
Go

jobcloud / php-kafka-lib

Star

PHP Kafka producer / consumer library with PHP Avro support, based on php-rdkafka

php kafka avro consumer producer avro-support

Updated Nov 23, 2020
PHP

wl4g / kafka_offset_tool

Star

KafkaOffsetTool is a lightweight tool for Kafka offset operation and maintenance

kafka offset consumer producer group

Updated Aug 6, 2019
Go

PHPMessageBus / eventbus-queue

Star

Event Bus asynchronous queuing with many Producer and Consumer implementations

php middleware queue rabbitmq php7 amqp beanstalkd supervisor event-sourcing eventbus consumer event-driven-microservices event-driven event-driven-programming producer producer-consumer eventbus-queue amqp-queue redisqueue

Updated Apr 16, 2017
PHP

wgarunap / generic-kafka-event-producer

Star

generic kafka event producer

json kafka avro producer

Updated Sep 25, 2020
Go

Tamal / ipcam-video-capture

Star

Capture video frame from IP Cam and send to Kinesis data streams for processing

video kinesis python3 capture producer ipcamera

Updated Jan 6, 2018
Python

mendrugory / galena

Star

Galena is a topic producer-consumer library built on top of GenStage for Elixir.

elixir messaging concurrency consumer producer producer-consumer genstage

Updated Aug 16, 2017
Elixir

116davinder / apache-kafka-backup-and-restore

Star

It will take backup of given topic and store that into either local filesystem or S3.It will also restore from given local filesystem or S3.

linux backup kafka restore topic s3 google-cloud-storage gcp python3 consumer threading partition apache-kafka producer producer-consumer aws-backup kafka-backup

Updated Sep 15, 2020
Python

daletskyi / KinesisProducerNet

Star

KinesisProducerNet is a .NET port of Amazon Kinesis Producer Library targeting .NET Standard

aws-kinesis producer amazon-web-services

Updated Oct 16, 2019
C#

sofyan48 / gempi

Star

Pubs/Subs model with AWS sqs

aws sqs pubsub consumer producer gempi

Updated Dec 22, 2019
Go

exiaoqu / ProducerConsumerProblemInJava

Star

Java solution for producer and consumer problem

java synchronization thread consumer producer

Updated Dec 14, 2018
Java

Improve this page

Add a description, image, and links to the producer 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 producer topic, visit your repo's landing page and select "manage topics."

You can’t perform that action at this time.