Skip to content

Instantly share code, notes, and snippets.

use std::env;
fn main() {
let mut tomlfile = "";
for argument in env::args() {
let tmp = &*argument;
if tmp.contains("toml=") {
println!("{}", &tmp[5 .. tmp.len()]);
tomlfile = &tmp[5 .. tmp.len()];
@asdfsx
asdfsx / consul.service
Created April 29, 2016 10:59 — forked from yunano/consul.service
/etc/systemd/system/consul.service
[Unit]
Description=consul agent
Requires=network-online.target
After=network-online.target
[Service]
EnvironmentFile=-/etc/sysconfig/consul
Environment=GOMAXPROCS=2
Restart=on-failure
ExecStart=/usr/local/sbin/consul agent $OPTIONS -config-dir=/etc/consul.d
import logging
import threading
import multiprocessing
import time
from kafka.client import KafkaClient
from kafka.common import FetchRequest, ProduceRequest
from kafka.consumer import SimpleConsumer
from kafka.producer import SimpleProducer