Hello,
I am new to Atlas and I have been trying to communicate with it through
Kafka.
When I create entities throught Atlas Web UI I see the event notifications
published under the ATLAS_ENTITIES topic.
However, I try to publish an ENTITY_CREATE message as shown in the
Technical User Guide to the ATLAS_HOOK topic and no entity is created and
no event is triggered under the ATLAS_ENTITIES HOOK.
I use : ./kafka-console-producer.sh --broker-list localhost:9027 --topic
ATLAS_HOOK
The message I publish is of the form:
{"version": {"version": "1.0.0"},"message": {"entities": [{"jsonClass":
"org.apache.atlas.typesystem.json.InstanceSerialization$_Reference","id":
{"jsonClass":
"org.apache.atlas.typesystem.json.InstanceSerialization$_Id","id":
"-1467290565135246000","version": 0,"typeName": "hbase_table","state":
"ACTIVE"},"typeName": "hbase_table","values": {"qualifiedName":
"TEST","description": "testing","name": "TEST"},"ClassificationNames":
[],"Classifications": {}}],"type": "ENTITY_CREATE","user": "admin"}}
I have tried to send it as a one line message and also to structure it as a
json file with its indentation but nothing seems to work.
Could you please provide some help on what I might be doing wrong?
Thank you very much,
Best regards
