Logstash Kafka Input Plugin Data has Type Already

Elastic Stack Logstash
4

If you cannot change the message from having a "type" field already I would just try using another field ie https://www.elastic.co/guide/en/logstash/current/plugins-inputs-kafka.html#plugins-inputs-kafka-add_field

input {
  kafka {
    add_field => {
      "log_origin" => "kafka" 
    }
    ...
}

output {
    elasticsearch {
      hosts   => [ "elasticsearchserver" ]
      index   => "%{log_origin}-%{+yyyy.MM.dd}"
      workers => 1
    }
}