All Projects → jcustenborder → Flume Ng Rabbitmq

jcustenborder / Flume Ng Rabbitmq

Licence: apache-2.0
Flume plugin for RabbitMQ

Programming Languages

java
68154 projects - #9 most used programming language

Labels

Projects that are alternatives of or similar to Flume Ng Rabbitmq

Nagios Plugins
450+ AWS, Hadoop, Cloud, Kafka, Docker, Elasticsearch, RabbitMQ, Redis, HBase, Solr, Cassandra, ZooKeeper, HDFS, Yarn, Hive, Presto, Drill, Impala, Consul, Spark, Jenkins, Travis CI, Git, MySQL, Linux, DNS, Whois, SSL Certs, Yum Security Updates, Kubernetes, Cloudera etc...
Stars: ✭ 1,000 (+1594.92%)
Mutual labels:  rabbitmq
Django Celery Tutorial
Django Celery Tutorial
Stars: ✭ 48 (-18.64%)
Mutual labels:  rabbitmq
Nservicebus.rabbitmq
RabbitMQ transport for NServiceBus
Stars: ✭ 55 (-6.78%)
Mutual labels:  rabbitmq
Phalcon Vm
Vagrant configuration for PHP7, Phalcon 3.x and Zephir development.
Stars: ✭ 43 (-27.12%)
Mutual labels:  rabbitmq
Node Server Project
基于 node.js + express 技术栈,采用MVC结构设计、JWT + RESTful API、PM2服务监控的Node服务器端项目框架.
Stars: ✭ 47 (-20.34%)
Mutual labels:  rabbitmq
Rabbitmq Operator
A Kubernetes Operator for RabbitMQ
Stars: ✭ 51 (-13.56%)
Mutual labels:  rabbitmq
Socket Io
基于Hyperf微服务协程框架开发的sokcet-io分布式系统
Stars: ✭ 38 (-35.59%)
Mutual labels:  rabbitmq
Spring Cloud Stream Demo
Simple Event Driven Microservices with Spring Cloud Stream
Stars: ✭ 58 (-1.69%)
Mutual labels:  rabbitmq
Tgir
Official repository for Thank Goodness It's RabbitMQ (TGIR)!
Stars: ✭ 48 (-18.64%)
Mutual labels:  rabbitmq
Rabbitmq Shovel
RabbitMQ Shovel plugin
Stars: ✭ 53 (-10.17%)
Mutual labels:  rabbitmq
Tackle
💯 percent reliable microservice communication
Stars: ✭ 44 (-25.42%)
Mutual labels:  rabbitmq
Kbframe
一款基于Laravel框架开发的现代化二次开发框架,是高性能,高效率,高质量的企业级开发框架,具有驱动领域,敏捷开发,轻易上手,高内聚低耦合,开箱即用等特点。
Stars: ✭ 47 (-20.34%)
Mutual labels:  rabbitmq
Microservices Using Rabbitmq
Python & Go microservices on Docker, using RabbitMQ for asynchronous IPC
Stars: ✭ 51 (-13.56%)
Mutual labels:  rabbitmq
Rabbitmq
RabbitMQ系统3.5.3版本中文完全注释(同时实现了RabbitMQ系统和插件源代码编译,根据配置文件创建RabbitMQ集群,创建连接RabbitMQ系统的客户端节点等相关功能,方便源代码的阅读)
Stars: ✭ 1,004 (+1601.69%)
Mutual labels:  rabbitmq
Tossit
Library for distributed job/worker logic.
Stars: ✭ 56 (-5.08%)
Mutual labels:  rabbitmq
Yii Queue
Queue extension for Yii 3.0
Stars: ✭ 38 (-35.59%)
Mutual labels:  rabbitmq
Dbblog
基于SpringBoot2.x+Vue2.x+ElementUI+Iview+Elasticsearch+RabbitMQ+Redis+Shiro的多模块前后端分离的博客项目
Stars: ✭ 1,045 (+1671.19%)
Mutual labels:  rabbitmq
Django Carrot
A lightweight task queue for Django using RabbitMQ
Stars: ✭ 58 (-1.69%)
Mutual labels:  rabbitmq
Commonx
基础框架
Stars: ✭ 57 (-3.39%)
Mutual labels:  rabbitmq
Yii2 Rabbitmq
RabbitMQ Extension for Yii2
Stars: ✭ 52 (-11.86%)
Mutual labels:  rabbitmq

Flume-ng RabbitMQ

This project provides both a RabbitMQ source and sink for Flume-NG. To use this plugin with your Flume installation, build from source using

mvn package

and put the resulting jar file in the lib directory in your flume installation.

This project is available under the Apache License.

Configuration of RabbitMQ Source

The configuration of RabbitMQ sources requires that you either declare an exchange name or a queue name.

The exchange name option is helpful if you have declared an exchange in RabbitMQ, but want to use a default named queue. If you have a predeclared queue that you want to receive events from, then you can simply declare the queue name and leave the exchange name out. Another optional configuration option is the declaration of topic routing keys that you want to listen to. This is a comma-delimited list.

Minimal Config Example

agent1.sources.rabbitmq-source1.channels = ch1  
agent1.sources.rabbitmq-source1.type = org.apache.flume.source.rabbitmq.RabbitMQSource  
agent1.sources.rabbitmq-source1.hostname = 10.10.10.173  

agent1.sources.rabbitmq-source1.queuename = log_jammin 
OR
agent1.sources.rabbitmq-source1.exchangename = log_jammin_exchange

Full Config Example

agent1.sources.rabbitmq-source1.channels = ch1  
agent1.sources.rabbitmq-source1.type = org.apache.flume.source.rabbitmq.RabbitMQSource  
agent1.sources.rabbitmq-source1.hostname = 10.10.10.173  

agent1.sources.rabbitmq-source1.queuename = log_jammin
OR
agent1.sources.rabbitmq-source1.exchangename = log_jammin_exchange

agent1.sources.rabbitmq-source1.topics = topic1,topic2
agent1.sources.rabbitmq-source1.username = rabbitmquser
agent1.sources.rabbitmq-source1.password = [email protected]$$w0rd!
agent1.sources.rabbitmq-source1.port = 12345
agent1.sources.rabbitmq-source1.virtualhost = virtualhost1

RabbitMQ Sink

Minimal Config Example

agent1.sinks.rabbitmq-sink1.channels = ch1  
agent1.sinks.rabbitmq-sink1.type = org.apache.flume.sink.rabbitmq.RabbitMQSink  
agent1.sinks.rabbitmq-sink1.hostname = 10.10.10.173  
agent1.sinks.rabbitmq-sink1.queuename = log_jammin

Full Config Example

agent1.sinks.rabbitmq-sink1.channels = ch1  
agent1.sinks.rabbitmq-sink1.type = org.apache.flume.sink.rabbitmq.RabbitMQSink  
agent1.sources.rabbitmq-source1.hostname = 10.10.10.173  
agent1.sources.rabbitmq-source1.queuename = log_jammin
agent1.sources.rabbitmq-source1.username = rabbitmquser
agent1.sources.rabbitmq-source1.password = [email protected]$$w0rd!
agent1.sources.rabbitmq-source1.port = 12345
agent1.sources.rabbitmq-source1.virtualhost = virtualhost1
agent1.sources.rabbitmq-source1.exchange = exchange1
Note that the project description data, including the texts, logos, images, and/or trademarks, for each open source project belongs to its rightful owner. If you wish to add or remove any projects, please contact us at [email protected].