我有一个logstash6.2x设置，读取kafka输入并将输出写入elasticsearch示例，在使用if/else时遇到问题
logstash配置看起来像

input {
  kafka {
    bootstrap_servers => '192.168.2.66:9092,192.168.2.67:9092,192.168.2.68:9092'
    topics => ["linum", "newdata"]
    codec => "json"
    type => "kafka"
    tags => ["linumsrvr1"]
    decorate_events => true
    }
}
output {
    if [topic] == "linum" {
        elasticsearch {
        hosts => ["192.168.2.32:9200"]
        action => "index"
        index => "linum-%{+YYYY.MM.dd}"
          }
   stdout {codec => rubydebug}
     } else {
     [kafka][topic_id] == "newdata" {
        elasticsearch {
        hosts => ["192.168.2.32:9200"]
        index => "newdata-%{+YYYY.MM.dd}"
          }
   stdout {codec => rubydebug}
     }
   }
}

当输出包含以“elasticsearch{../“日}”
由于某些原因，当我使用“if”或“if”+“else”语句时，似乎没有任何数据被发送到elasticsearch。
我想为这两个主题创建两个单独的索引。
我会感激一些关于我做错了什么的指导。
谢谢