You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@atlas.apache.org by Jo MailingList <jo...@gmail.com> on 2017/12/20 09:53:18 UTC

Problems publishing messages to ATLAS_HOOK

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

Fwd: Problems publishing messages to ATLAS_HOOK

Posted by Jo MailingList <jo...@gmail.com>.
Hello,

Sorry for disturbing, I already found the problem, missing attributes for
the enity to be created.

Thank you very much

---------- Forwarded message ----------
From: Jo MailingList <jo...@gmail.com>
Date: 2017-12-20 10:53 GMT+01:00
Subject: Problems publishing messages to ATLAS_HOOK
To: user@atlas.apache.org


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