triton

triton copied to clipboard

Background

Triton is a high performance, high stability plug-in type messaging middleware consumer written in pure Go language,which supports the mainstream message queues in the market, such as Kafka, RabbitMQ, RocketMQ, NSQ, etc.And it is easy to be extended to meet different business requirements in production environment.

Document

Document

中文文档

Framework

The framework of triton is shown as below.

Quickstart

Consumer messages from kafka by triton.

1. Start zookeeper

./bin/zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties

2. Start kafka

./bin/kafka-server-start /usr/local/etc/kafka/server.properties

3. Create topic

./bin/kafka-topics  --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

4. Modify config for kafka in triton

{
  "enabled": {
    "kafka": true
  },
  "kafka": [
    {
      "consumerGroup": "test0",
      "consumerCount": 1,
      "host": [
        "127.0.0.1:9092"
      ],
      "sasl": {
        "enabled": false,
        "user": "",
        "password": ""
      },
      "topic": "test",
      "failTopic": "xes_exercise_fail",
      "tplMode": 1,
      "tplName": "test"
    }
  ]
}

• tpl config

[test]
-={{$ctx := .Ctx}}{{$arg := .Data}}{{printf "%v\n" $arg}}
-=@NONE

5. Run

tar -zxvf triton.tar.gz
cd triton/
make
./bin/triton -c ../conf/conf.ini

Contact us

（微信扫一扫，申请加入开发讨论微信群）