- + 00version.go - + adminapi.go - + adminoptions.go - + build_glibc_linux_amd64.go - + config.go - + consumer.go - + context.go - + error.go - + error_gen.go - + event.go - + generated_errors.go - + handle.go - + header.go - + kafka.go - + log.go - + message.go - + metadata.go - + misc.go - + mockcluster.go - + offset.go - + producer.go - + time.go @@ -2015,7 +2015,7 @@
LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client
-const LibrdkafkaLinkInfo = "static glibc_linux_amd64 from librdkafka-static-bundle-v2.3.0-RC4.tgz"
+ const LibrdkafkaLinkInfo = "static glibc_linux_amd64 from librdkafka-static-bundle-v2.3.0.tgz"
OffsetBeginning represents the earliest offset (logical)
@@ -2039,7 +2039,7 @@const PartitionAny = int32(C.RD_KAFKA_PARTITION_UA)
type ACLBindingFilter = ACLBinding
type ACLBindingFilters []ACLBindingFilter
type ACLBindings []ACLBinding
func (a ACLBindings) Len() int
func (a ACLBindings) Less(i, j int) bool
func (a ACLBindings) Swap(i, j int)
type ACLOperation int
type ACLPermissionType int
- `ctx` - context with the maximum amount of time to block, or nil for indefinite. -- `topics` - Collection of topics to describe. This should not be nil/empty. +- `topics` - Collection of topics to describe. This should not have nil + topic names. - `options` - DescribeTopicsAdminOption options.
@@ -2755,7 +2756,7 @@
- `ctx` - context with the maximum amount of time to block, or nil for indefinite. -- `topicPartitionOffsets` - a map from TopicPartition to OffsetSpec, it holds either the OffsetSpec enum value or timestamp. +- `topicPartitionOffsets` - a map from TopicPartition to OffsetSpec, it + holds either the OffsetSpec enum value or timestamp. Must not be nil. - `options` - ListOffsetsAdminOption options.
@@ -2934,7 +2936,7 @@
type AlterConfigOpType int
type AlterOperation int
func (e AssignedPartitions) String() string
type ConfigMap map[string]ConfigValue