Kafka in and out

sudo gor --input-raw :8080 --output-kafka-host '192.168.0.1:9092,192.168.0.2:9092' --output-kafka-topic 'kafka-log'
gor --input-kafka-host '192.168.0.1:9092,192.168.0.2:9092' --input-kafka-topic 'kafka-log' --output-stdout

Default payload is Gor text. JSON: --output-kafka-json-format / --input-kafka-json-format.

  • Output SASL: --output-kafka-use-sasl, --output-kafka-mechanism, --output-kafka-username, --output-kafka-password
  • Input SASL: --input-kafka-use-sasl, --input-kafka-mechanism, --input-kafka-username, --input-kafka-password
  • TLS: --kafka-tls-ca-cert, --kafka-tls-client-cert, --kafka-tls-client-key

--input-kafka-offset default -1 (newest), -2 oldest. Speed: "-2|200%". Sort buffer: --input-kafka-buffer-size.

Elasticsearch.