Discover keedio/flume-ng-kafka-avro-sink Open Source project

FTP network server is source of events for Apache-flume

266

flume-ftp-source

Hadoop Ecosystem Builder: Build, package, test and deploy your Hadoop ecosystem project.

buildoop

Groovy

kafka-hue

Hue application for Apache Kafka

Mako

flume-taildirectory-source

avro-schema-repo

openshift-cassandra

Nifi-JsonProcessor

Sample project development of a custom apache nifi Processor in Scala language

A Java Math.BigDecimal Implementation of Core Mathematical Functions

bigdecimal-math

openstack-log-processor

Quick-and-dirty usage example of of Bing Voice Recognition RESTful API

bing-speech-to-text-example

This repository contains a collection of nagios plugins to monitor Hadoop ecosystem.

nagios-hadoop

Keedio's Hadoop Watcher is a functionality for watching a hdfs path for changes.

Hadoop-Watcher

Hue application for Apache Storm

storm-hue

Mako

keedio-stacks

Ambari Stacks made by keedio

Let’s Big Data. Hue is an open source Web interface for analyzing data with Hadoop and Spark. http://gethue.com

hue

Flume interceptor to enrich event body to JSON format with some extra data

flume-enrichment-interceptor-skeleton

Buildoop recipes, for easy package version maintenance

buildoopRecipes

Shell

Flume-ng-source-VFS

Flume-ng-source-VFS is a custom Apache Flume source component for processing files under supported file sytems by Apache-Commons-Vfs2™

OpenStack log collection PoC

openstack-operations-poc

Flume sink to publish in Microsoft Azure Event Hubs

flume-ng-event-hub-sink

Custom Flume Sink for sending events via GELF protocol.

openshift-kafka

Shell

Flume-sink-Gelf

Training repo for OpenShift

opensfhit-training

Keedio's VFS2-Monitor is a feature for monitoring changes in directories of supported file systems.

VFS2-Monitor

Azure Blob Storage shared connection service for Apache NiFi

nifi-azure-blob-connection-service-bundle

flume-opsec-source

tailer-example

A flume sink to send events over a TCP connection

flume-tcp-sink

A Flume HBase Sink serializer for split CSV events into HBase Columns

flume-hbase-csv-serializer

Scripts to process the Air Pollution Database of the European Environment Agency

air-pollution-data

nodejs_training

Training repo for Node.js

Azure Blob Storage NiFi processors

nifi-azure-blob-storage-processor-bundle

ganglia-storm

Skeleton of a cacheable Flume interceptor.

flume-cacheable-interceptor-skeleton

json4s encoder/decoder for kafka

kafka-json4s-codecs

Serializer for build Avro file using Flume event headers

flume-headers-to-avro-serializer

flume-configurator

AvroRepoKafkaProducerTest

This bolt operates filtering data from stream of tuples, according a mapped list of crterias specified in Topology's config

Storm-filterkey-bolt

tuneable-data-generator

Simple Apache Flink job to inyect data in ElasticSearch via Keedio Stacks

CsvToElasticSearchInjector

Custom ambari-admin style

ambari-admin

flume-filedump-interceptor

Flume Hbase Serializer to split event body into chunks to send to HBase columns

flume-hbase-offset-serializer

front-kds-logs

Some kafka tools for testing purposes

kafka-utilities

flume-event-header-fields-copy-interceptor

Some tools to test custom flume sources

flume-stress-test-tools

Shell

kafka-log4j-appender

Log4j Appender sending log messages to kafka topics

Vagrant based test environment

keedio-vagrant

Ruby

ambari-web

This repository contains required modifications to ambari-web javascripts in order to deploy a keedio stack with ambari