Exemple d'utilisation du tKafkaInput
Dans le script de Job de l'exemple du tKafkaInput, seuls la version Kafka, la liste des brokers et le nom du topic Kafka sont spécifiés, laissant les autres paramètres configurés par défaut.
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\""
}