- + 00version.go - + adminapi.go - + adminoptions.go - + build_glibc_linux.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 - + testhelpers.go - + time.go @@ -1562,7 +1562,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
type AlterOperation int
func (e AssignedPartitions) String() string
type ConfigMap map[string]ConfigValue
type ConfigSource int
type ConfigValue interface{}