Confluent Kafka Golang Client v0.11.6 Release Notes
Release Date: 2018-10-25 // over 5 years ago-
Admin API
๐ This release adds support for the Topic Admin API (KIP-4):
- Create and delete topics
- Increase topic partition count
- ๐ง Read and modify broker and topic configuration
Requires librdkafka >= v0.11.6
results, err := a.CreateTopics( ctx, // Multiple topics can be created simultaneously// by providing additional TopicSpecification structs here. []kafka.TopicSpecification{{ Topic: "mynewtopic", NumPartitions: 20, ReplicationFactor: 3}})
More examples.
๐ Fixes and enhancements
- ๐ง Make sure plugins are set before other configuration options (#225, @dtheodor)
- ๐ Fix metadata memory leak
- ๐ฏ Clone config before mutating it in NewProducer and NewConsumer (@vlad-alexandru-ionescu)
- Enable Error events to be emitted from librdkafka errors, e.g., ErrAllBrokersDown, et.al (#200)