awslabs/aws-fluent-plugin-kinesis

Amazon Kinesis output plugin for Fluentd

Language: Ruby - Size: 466 KB - Last synced: 8 days ago - Pushed: about 1 month ago - Stars: 292 - Forks: 97

TWAICE/node-kinesis-producer

Kinesis Producer library for NodeJS

Language: TypeScript - Size: 3.34 MB - Last synced: 6 days ago - Pushed: 24 days ago - Stars: 5 - Forks: 2

a8m/kinesis-producer

An aggregated records producer for Amazon Kinesis

Language: Go - Size: 49.8 KB - Last synced: about 1 month ago - Pushed: 11 months ago - Stars: 146 - Forks: 50

bufferapp/kiner

Python AWS Kinesis Producer with error handling and thread support.

Language: Python - Size: 37.1 KB - Last synced: about 1 month ago - Pushed: over 1 year ago - Stars: 44 - Forks: 20

JoseLuisSR/awsmeter

JMeter plugin to execute load test over Kinesis Data Stream, SQS Standard and FIFO Queues, SNS Standard and FIFO Topics, Cognito AWS services.

Language: Java - Size: 11.3 MB - Last synced: 9 days ago - Pushed: 5 months ago - Stars: 20 - Forks: 14

lucasvsme/poc-spring-aws-kinesis-multistream

Publishing and consuming records from multiple Kinesis streams using the Kinesis Client Library (KCL 2.x)

Language: Java - Size: 183 KB - Last synced: 6 months ago - Pushed: 6 months ago - Stars: 1 - Forks: 0

coryodaniel/docker-kinesis-agent

AWS Kinesis Agent on Debian Slim 9

Language: Makefile - Size: 2.93 KB - Last synced: 16 days ago - Pushed: over 4 years ago - Stars: 8 - Forks: 2

averemee-si/oraadr-kafka

Oracle Database Automatic Diagnostic Repository messages (alert.log & listener.log) to Apache Kafka or Amazon Kinesis transfer

Language: Java - Size: 36.1 KB - Last synced: 8 months ago - Pushed: 8 months ago - Stars: 0 - Forks: 2

averemee-si/oralog

Ingestion tool for various database logs

Language: Java - Size: 117 KB - Last synced: 8 months ago - Pushed: 8 months ago - Stars: 0 - Forks: 1

thomasdesr/firehose-batcher

Provide a lightweight wrapper to batch record sends to AWS Kinesis Firehose

Language: Go - Size: 1.63 MB - Last synced: 10 months ago - Pushed: over 6 years ago - Stars: 1 - Forks: 1

TWAICE/nestjs-kinesis-producer

Kinesis Producer Library for Nestjs

Language: TypeScript - Size: 313 KB - Last synced: 6 days ago - Pushed: about 3 years ago - Stars: 8 - Forks: 1

ouzi-dev/kinesis-producer Fork of a8m/kinesis-producer

An aggregated records producer for Amazon Kinesis

Language: Go - Size: 69.3 KB - Last synced: 10 months ago - Pushed: about 3 years ago - Stars: 1 - Forks: 1

scblur869/mqtt-to-kinesis

subscribes to a MQTT Topic and routes that data to kinesis in 5mb batches

Language: Go - Size: 206 KB - Last synced: about 1 year ago - Pushed: about 1 year ago - Stars: 0 - Forks: 0

natigold/streaming-demo

Node v16 ES6 example of both Amazon Kinesis and Kafka producers and consumers, using different methods

Language: JavaScript - Size: 127 KB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

aws-samples/aws-lambda-kinesis-aggregated-event-filtering

Sample project which shows how you can use partition keys to trigger a lambda for specific user records when kinesis aggregation is applied manually

Language: TypeScript - Size: 947 KB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

simukappu/aws-fluent-plugin-kinesis Fork of awslabs/aws-fluent-plugin-kinesis

Fluent Plugin for Amazon Kinesis

Language: Ruby - Size: 466 KB - Last synced: 2 months ago - Pushed: 2 months ago - Stars: 1 - Forks: 0

yokawasa/kinesis-bulk-loader

A Golang tool that put bulk messages in parallel to AWS Kinesis Data Stream

Language: Go - Size: 41 KB - Last synced: about 1 month ago - Pushed: over 2 years ago - Stars: 1 - Forks: 0

spaulaus/streaming-data-explorers

Simple scripts for learning about Kafka and Kinesis

Language: Python - Size: 9.77 KB - Last synced: about 1 year ago - Pushed: over 3 years ago - Stars: 0 - Forks: 0

simukappu/sample-kinesis-android-client

Sample android application as Amazon Kinesis client

Language: Java - Size: 128 KB - Last synced: about 1 year ago - Pushed: over 6 years ago - Stars: 7 - Forks: 2

enryold/quasar-flow

Handle data flows using quasar fibers and reactive-streams.

Language: Java - Size: 1.52 MB - Last synced: about 1 year ago - Pushed: almost 4 years ago - Stars: 2 - Forks: 2

smoghal/kinesis-data-ingestion

Amazon Kinesis data ingestion using the "forwarder pattern"

Language: Python - Size: 29.3 KB - Last synced: about 1 year ago - Pushed: almost 4 years ago - Stars: 0 - Forks: 0

averemee-si/oraaud-kafka

Oracle audit files to Apache Kafka/Amazon MKS/Amazon Kinesis transfer

Language: Java - Size: 47.9 KB - Last synced: about 1 year ago - Pushed: about 3 years ago - Stars: 0 - Forks: 1

mtlpy/kinesis_producer

Python producer for AWS Kinesis Stream with record aggregation (Work In Progress)

Language: Python - Size: 19.5 KB - Last synced: about 1 month ago - Pushed: about 7 years ago - Stars: 20 - Forks: 20

sakib142/asynchronous-interservice-communication

Solution for interservice communication between various microservices using kafka and kinesis

Language: Java - Size: 40 KB - Last synced: about 1 year ago - Pushed: almost 6 years ago - Stars: 1 - Forks: 0

sajithpro/kinesis-producer

Wrapper around AWS Kinesis Producer with retry and queue logic.

Size: 1000 Bytes - Last synced: 27 days ago - Pushed: about 5 years ago - Stars: 0 - Forks: 0

mulloymorrow/AsyncKinesisProducer

Async AWS Kinesis producer for python3 via multiprocessing

Language: Python - Size: 2.93 KB - Last synced: 23 days ago - Pushed: almost 6 years ago - Stars: 0 - Forks: 0

JensVerneuer/kinesis

Language: TypeScript - Size: 10.7 KB - Last synced: about 1 year ago - Pushed: about 6 years ago - Stars: 0 - Forks: 0