What's Changed

• Wait for topic by @m110 in #40

• Introduce SubscribeInitializeWithContext - same as SubscribeInitialize but you can pass context.Context to manage deadlines/timeouts.

• SubscribeInitialize now waits for all partitions of the topic to be created across brokers. This means once the function returns, the topic is ready for consumers to connect. This can be disabled with DoNotWaitForTopicCreation.

Full Changelog: v3.1.1...v3.1.2