Topic Management from Configuration

[OneCricketeer]

Now that AdminClient was added, I suggest adding a way that, during the lifecycle startup, then topics are created if they don't already exist.

Relevant methods:

• https://kafka.apache.org/11/javadoc/org/apache/kafka/clients/admin/AdminClient.html#createTopics-java.util.Collection-
• https://kafka.apache.org/11/javadoc/org/apache/kafka/clients/admin/NewTopic.html

Configuration suggestion

topics:
  - name: foo
    partitions: 3
    replicationFactor: 3
  # topic with additional configuration
  - name: bar
    partitions: 1
    replicationFactor: 5
    config:
      cleanup.policy: compact

Additionally, would be nice to have a healthcheck that verifies topic existance + configuration details, but that can be future issue.

[natalie-zamani]

Hey @Cricket007, thanks for another good suggestion. :) Would you have any interest in taking a crack at contributing?

[OneCricketeer]

Ref #19

Got the YAML parser down, I think. Not sure how the Discoverable interface works, but doesn't seem to pick up that Factory class.

Also, since the AdminClient is required to create topics, I believe those would go together as part of a Bundle rather than a Factory? Not too familiar with Dropwizard terms here...