diff --git a/kafka/api.html b/kafka/api.html index 15687126..2fc91557 100644 --- a/kafka/api.html +++ b/kafka/api.html @@ -14,7 +14,7 @@ @@ -1810,70 +1810,70 @@

- + 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 @@ -1905,7 +1905,7 @@

)

LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client -

const LibrdkafkaLinkInfo = "static glibc_linux_amd64 from librdkafka-static-bundle-v2.5.3.tgz"
+
const LibrdkafkaLinkInfo = "static glibc_linux_amd64 from librdkafka-static-bundle-v2.6.0-RC2.tgz"

OffsetBeginning represents the earliest offset (logical)

const OffsetBeginning = Offset(C.RD_KAFKA_OFFSET_BEGINNING)
@@ -1924,7 +1924,7 @@

const PartitionAny = int32(C.RD_KAFKA_PARTITION_UA)

func - + LibraryVersion

+ WriteErrorCodes

+ ACLBinding

+ ACLBindingFilter

ACLBinding

type - + ACLBindingFilters

ACLBindingFilter

type - + ACLBindings

ACLBinding

func (ACLBindings) - + Len

ACLBindings) Len() int

func (ACLBindings) - + Less

ACLBindings) Less(i, j int) bool

func (ACLBindings) - + Swap

ACLBindings) Swap(i, j int)

type - + ACLOperation

+ ACLOperationFromString

+ String

+ ACLPermissionType

+ ACLPermissionTypeFromString

+ String

+ AdminClient

+ NewAdminClient

+ NewAdminClientFromConsumer

+ NewAdminClientFromProducer

+ AlterConfigs

+ AlterConsumerGroupOffsets

+ AlterUserScramCredentials

+ Close

+ ClusterID

+ ControllerID

+ CreateACLs

+ CreatePartitions

+ CreateTopics

+ DeleteACLs

+ DeleteConsumerGroups

+ DeleteRecords

+ DeleteTopics

+ DescribeACLs

+ DescribeCluster

+ DescribeConfigs

+ DescribeConsumerGroups

+ DescribeTopics

+ DescribeUserScramCredentials

+ GetMetadata

+ IncrementalAlterConfigs

+ IsClosed

+ ListConsumerGroupOffsets

+ ListConsumerGroups

+ ListOffsets

+ SetOAuthBearerToken

+ SetOAuthBearerTokenFailure

+ SetSaslCredentials

+ String

+ AdminOption

+ AdminOptionIncludeAuthorizedOperations

+ SetAdminOptionIncludeAuthorizedOperations

+ AdminOptionIsolationLevel

+ SetAdminIsolationLevel

+ AdminOptionMatchConsumerGroupStates

+ SetAdminMatchConsumerGroupStates

+ AdminOptionOperationTimeout

+ SetAdminOperationTimeout

+ AdminOptionRequestTimeout

+ SetAdminRequestTimeout

+ AdminOptionRequireStableOffsets

+ SetAdminRequireStableOffsets

+ AdminOptionValidateOnly

+ SetAdminValidateOnly

+ AlterConfigOpType

+ String

+ AlterConfigsAdminOption

+ AlterConsumerGroupOffsetsAdminOption

+ AlterConsumerGroupOffsetsResult

+ AlterOperation

int

func (AlterOperation) - + String

+ AlterUserScramCredentialsAdminOption

+ AlterUserScramCredentialsResult

+ AssignedPartitions

+ String

AssignedPartitions) String() string

type - + BrokerMetadata

+ ConfigEntry

+ StringMapToConfigEntries

+ StringMapToIncrementalConfigEntries

+ String

+ ConfigEntryResult

+ String

+ ConfigMap

string]ConfigValue

func (ConfigMap) - + Get

+ Set

+ SetKey

+ ConfigResource

+ String

+ ConfigResourceResult

+ String

+ ConfigSource

+ String

+ ConfigValue

+ Consumer

+ NewConsumer

+ Assign

+ Assignment

+ AssignmentLost

+ Close

+ Commit

+ CommitMessage

+ CommitOffsets

+ Committed

+ Events

+ GetConsumerGroupMetadata

+ GetMetadata

+ GetRebalanceProtocol

+ GetWatermarkOffsets

+ IncrementalAssign

+ IncrementalUnassign

+ IsClosed

+ Logs

+ OffsetsForTimes

+ Pause

+ Poll

+ Position

+ QueryWatermarkOffsets

+ ReadMessage

+ Resume

+ Seek

+ SeekPartitions

+ SetOAuthBearerToken

+ SetOAuthBearerTokenFailure

+ SetSaslCredentials

+ StoreMessage

+ StoreOffsets

+ String

+ Subscribe

+ SubscribeTopics

+ Subscription

+ Unassign

+ Unsubscribe

+ ConsumerGroupDescription

+ ConsumerGroupListing

+ ConsumerGroupMetadata

+ NewTestConsumerGroupMetadata

+ ConsumerGroupResult

+ String

+ ConsumerGroupState

+ ConsumerGroupStateFromString

+ String

+ ConsumerGroupTopicPartitions

+ String

ConsumerGroupTopicPartitions) String() string

type - + CreateACLResult

+ CreateACLsAdminOption

+ CreatePartitionsAdminOption

+ CreateTopicsAdminOption

+ DeleteACLsAdminOption

+ DeleteACLsResult

DescribeACLsResult

type - + DeleteConsumerGroupsAdminOption

+ DeleteConsumerGroupsResult

+ DeleteRecordsAdminOption

+ DeleteRecordsResult

+ DeleteRecordsResults

+ DeleteTopicsAdminOption

+ DeletedRecords

+ DescribeACLsAdminOption

+ DescribeACLsResult

+ DescribeClusterAdminOption

+ DescribeClusterResult

+ DescribeConfigsAdminOption

+ DescribeConsumerGroupsAdminOption

+ DescribeConsumerGroupsResult

+ DescribeTopicsAdminOption

+ DescribeTopicsResult

+ DescribeUserScramCredentialsAdminOption

+ DescribeUserScramCredentialsResult

+ Error

+ NewError

+ Code

+ Error

+ IsFatal

+ IsRetriable

+ IsTimeout

+ String

+ TxnRequiresAbort

+ ErrorCode

+ String

+ Event

+ Handle