I added a TopicAdminService that creates a new topic in Kafka based on the type value in the StreamRecord.