| Note |
|---|
Data Stream = Kafka Topic + Data Governance |
...
Admin Client and Data Governance
...
Define Properties : bootstrap.servers=broker-1:8684
Create Admin Client : adminClient = new AdminClient<>(properties)
Perform Action such as create topic = adminClient.createTopic(topic)
Deleting Records
| Info |
|---|
This action is more complex because specific records in topic need to be deleted. |