diff --git a/cmd/test/benthos_in_proc/benthos_in_proc b/cmd/test/benthos_in_proc/benthos_in_proc deleted file mode 100755 index 0798d1b810..0000000000 Binary files a/cmd/test/benthos_in_proc/benthos_in_proc and /dev/null differ diff --git a/config/kafka_bridge.json b/config/kafka_bridge.json new file mode 100644 index 0000000000..c65ce7bf4a --- /dev/null +++ b/config/kafka_bridge.json @@ -0,0 +1,49 @@ +{ + "input": { + "type": "fan_in", + "fan_in": { + "inputs": [ + { + "type": "kafka", + "kafka": { + "addresses": [ + "localhost:9092" + ], + "topic": "benthos_stream", + "consumer_group": "benthos_consumer_group", + "client_id": "benthos_kafka_input", + "partition": 0 + } + }, + { + "type": "ditto", + "kafka": { + "partition": 1 + } + }, + { + "type": "ditto", + "kafka": { + "partition": 2 + } + }, + { + "type": "ditto", + "kafka": { + "partition": 3 + } + } + ] + } + }, + "output": { + "type": "zmq4", + "zmq4": { + "socket_type": "PUSH", + "bind": true, + "addresses": [ + "tcp://*:5556" + ] + } + } +}