Код IT
← Каталог

Справочник по Logstash — 2. Приём JSON через HTTP и отправка в Kafka

Фрагмент из «Справочник по Logstash»: 2. Приём JSON через HTTP и отправка в Kafka.

ruby infra-securityencyclopedia8-04-devops-ci-cd-3119 embed URL статья в энциклопедии
Ruby main.rb 
input {
  http {
    port => 8080
    codec => json
  }
}

filter {
  mutate {
    add_field => { "received_at" => "%{@timestamp}" }
  }
}

output {
  kafka {
    bootstrap_servers => "kafka:9092"
    topic_id => "incoming-events"
    compression_type => "snappy"
  }
}
input {
  http {
    port => 8080
    codec => json
  }
}

filter {
  mutate {
    add_field => { "received_at" => "%{@timestamp}" }
  }
}

output {
  kafka {
    bootstrap_servers => "kafka:9092"
    topic_id => "incoming-events"
    compression_type => "snappy"
  }
}