Hi. I receive the following error message when I try to run kafka loading job:
org.json.JSONException: JSONObject[“security.protocol”] not found.
[ERROR] Kafka broker check failed!
Semantic Check Fails: Failed to split kafka topic partition of job kafka_events
Failed to run loading job kafka_events
kafka.json:
{
“broker”: “kf1.test.dev.mysystem.com:9092”,
“kafka_config”: {
“group.id”:“tigergraph”,
“security.protocol”: “SASL_PLAINTEXT”,
“sasl.mechanism”:“PLAIN”,
“key.serializer”: “org.apache.kafka.common.serialization.StringSerializer”,
“value.serializer”: “org.apache.kafka.common.serialization.StringSerializer”
}
}
create_kafka_ds.gsql:
CREATE DATA_SOURCE KAFKA kafka1 FOR GRAPH merger
SET kafka1 = “/home/tigergraph/tiger/merger_graph/kafka/kafka.json”
topic.json:
{
“topic”: “normalOut”,
“partition_list”: []
}
run command:
gsql -g merger ‘RUN LOADING JOB kafka_events USING input_file = “$kafka1:/home/tigergraph/tiger/merger_graph/kafka/topic.json”’