About partition, how can this configuration? about fluent-plugin-kafka HOT 3 CLOSED

If I configure the partition parameter to be 8, I just tip the error:

Do you mean you write following configuration?

  <topic>
    topic ngx_order_log
    partition 0
    offset -1
  </topic>
  <topic>
    topic ngx_order_log
    partition 1
    offset -1
  </topic>
  ...
  <topic>
    topic ngx_order_log
    partition 7
    offset -1
  </topic>

from fluent-plugin-kafka.

Thank you very much. I have tried this way, it seems that I don't support it.
But I use logstash to do this.

from fluent-plugin-kafka.

I see.
Lastet this plugin supports kafka_gourp and Treasure Data released kafka consumer for fluentd.

https://github.com/treasure-data/kafka-fluentd-consumer

If you have a chance to use fluentd in the future, please try it.

from fluent-plugin-kafka.