v0.11.6
版本发布时间: 2018-10-25 15:46:58
confluentinc/confluent-kafka-go最新发布版本:v2.3.0(2023-10-25 23:55:38)
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)