kafka partition issus

[kadisyy]

conf:
`[kafkaInputTest]
type = "KafkaInput"
topic = "jie"
addrs = ["172.20.3.50:9092"]
splitter = "KafkaSplitter"
decoder = "ProtobufDecoder"

[KafkaSplitter]
type = "NullSplitter"
use_message_bytes = true
`

But error:

2018/09/17 16:01:18 Input 'kafkaInputTest' error: kafka server: In the middle of a leadership election, there is currently no leader for this partition and hence it is unavailable for writes.