{"type":"doc","content":[{"type":"panel","attrs":{"panelType":"info"},"content":[{"type":"paragraph","content":[{"text":"Available from version 2.1.3-gradius","type":"text"}]}]},{"type":"paragraph","content":[{"text":"Regarding Kafka, it has 2 main purposes in Onesait Platform:","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Sending data to Onesait Platform via Kafka topics","type":"text","marks":[{"type":"link","attrs":{"href":"https://onesaitplatform.atlassian.net/wiki/spaces/OP/pages/1081541"}}]}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Kafka notification topics for ontologies","type":"text","marks":[{"type":"link","attrs":{"href":"https://onesaitplatform.atlassian.net/wiki/spaces/OP/pages/1081541/APIs+de+cliente+How+to+send+receive+data+to+from+the+Kafka+Broker+of+the+Platform"}}]}]}]}]},{"type":"paragraph","content":[{"text":"When Multitenancy is enabled, the use of Kafka changes slightly from the default behaviour. If the default tenant and vertical are being used, nothing changes compared to the two previous guides. However, ","type":"text"},{"text":"if a different tenant or vertical are used","type":"text","marks":[{"type":"underline"},{"type":"strong"}]},{"text":", then the following changes are needed to be taken into account.","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Kafka topic names related to ontologies","type":"text"},{"type":"hardBreak"},{"type":"hardBreak"},{"text":"By default there are 2 topic prefixes, one for the input topic (ONTOLOGY) and an other one for the notification topics (ONTOLOGY_OUTPUT). The topic names used will be as follows:","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Input topic: ---","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Notification topic: ---","type":"text"},{"type":"hardBreak"},{"type":"hardBreak"},{"text":"For example, we have the ontology named “MyOntology” which is marked as both kafka input and kafka notification. ","type":"text"},{"type":"hardBreak"},{"text":"We then create a Digital Client with a token on a different tenant, but in the default vertical.","type":"text"},{"type":"hardBreak"}]},{"type":"mediaSingle","attrs":{"layout":"center"},"content":[{"type":"media","attrs":{"width":1096,"id":"2d6326c1-a438-4b94-9070-062da6218385","collection":"contentId-1027964933","type":"file","height":759}}]},{"type":"paragraph","content":[{"type":"hardBreak"},{"text":"If we want to insert data into the ontology via Kafka, the topic name to write to will be: ","type":"text"},{"text":"ONTOLOGY-ONESAITPLATFORM-TENANT_RENE-MYONTOLOGY","type":"text","marks":[{"type":"code"}]},{"type":"hardBreak"},{"type":"hardBreak"},{"text":"If we want to listen to the kafka notificiation topic, this will be named: ","type":"text"},{"text":"ONTOLOGY_OUTPUT-ONESAITPLATFORM-TENANT_RENE-MYONTOLOGY","type":"text","marks":[{"type":"code"}]},{"type":"hardBreak"},{"type":"hardBreak"}]}]}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Security: Digital Clients and Kafka users","type":"text"},{"type":"hardBreak"},{"type":"hardBreak"},{"text":"Onesait Platform has it’s own Kafka Security plugin, where digital clients represent Kafka users.","type":"text"},{"type":"hardBreak"},{"text":"When connecting to Kafka, a JAAS file will be used, indicating de digital client name as “username” and a token as the “password”.","type":"text"},{"type":"hardBreak"},{"text":"If multitenancy its enabled and we are using a different vertical or tenant than the default one, the kafka “username” will change to --.","type":"text"},{"type":"hardBreak"},{"type":"hardBreak"},{"text":"Lets use the same Ontology and Digital Client as in the last example. We want to connect to Kafka, but using the tenant named “tenant_rene”. In this case, the Kafka “username” will be: ","type":"text"},{"text":"MyKafkaClient-onesaitplatform-tenant_rene ","type":"text","marks":[{"type":"code"}]},{"text":"and tthe token created for that tenant:","type":"text"},{"type":"hardBreak"}]},{"type":"mediaSingle","attrs":{"layout":"center"},"content":[{"type":"media","attrs":{"width":1075,"id":"5c3010f5-d4fa-41aa-8186-be1d4ba0e939","collection":"contentId-1027964933","type":"file","height":600}}]},{"type":"paragraph"}]}]},{"type":"paragraph","marks":[{"type":"indentation","attrs":{"level":1}}],"content":[{"text":"This can be seen when asking Kafka for de ACL/permissions of each topic and user:","type":"text"}]},{"type":"mediaSingle","attrs":{"layout":"center"},"content":[{"type":"media","attrs":{"width":899,"id":"3ff0ed11-e290-4b1b-82c2-ff4561af2669","collection":"contentId-1027964933","type":"file","height":117}}]},{"type":"paragraph"}],"version":1}

Browser not supported