tKafkaInput example
In the following Job script example of tKafkaInput, only the Kafka version, the broker list, and the Kafka topic name are specified, leaving all the other parameter as default.
setSettings {
KAFKA_VERSION : "KAFKA_0_10_0_1",
BROKER_LIST : "\"192.168.6.56:9093,192.168.6.57:9094,192.168.6.58:9095\"",
KAFKA_TOPIC : "\"mytopic\""
}