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)