This repository was archived by the owner on Apr 2, 2024. It is now read-only.
This repository was archived by the owner on Apr 2, 2024. It is now read-only.
kafka partition issus #1996
Description
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.