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.
The framework of triton is shown as below.
./bin/zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties./bin/kafka-server-start /usr/local/etc/kafka/server.properties./bin/kafka-topics --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test{
"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}}
-=@NONEtar -zxvf triton.tar.gz
cd triton/
make
./bin/triton -c ../conf/conf.ini
（微信扫一扫，申请加入开发讨论微信群）