diff --git a/.semaphore/semaphore.yml b/.semaphore/semaphore.yml index 4c9c99472..19af0e375 100644 --- a/.semaphore/semaphore.yml +++ b/.semaphore/semaphore.yml @@ -6,7 +6,7 @@ agent: global_job_config: env_vars: - name: LIBRDKAFKA_VERSION - value: v2.1.0 + value: v2.1.1-RC1 prologue: commands: - checkout diff --git a/CHANGELOG.md b/CHANGELOG.md index 356aa3ad3..01b299a3f 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,7 +1,18 @@ # Confluent's Golang client for Apache Kafka +## v2.1.1 + +This is a maintenance release: + +confluent-kafka-go is based on librdkafka v2.1.1, see the +[librdkafka v2.1.1 release notes](https://github.com/confluentinc/librdkafka/releases/tag/v2.1.1) +for a complete list of changes, enhancements, fixes and upgrade considerations. + + ## v2.1.0 +This is a feature release: + * Added Consumer `SeekPartitions()` method to seek multiple partitions at once and deprecated `Seek()` (#940). * [KIP-320](https://cwiki.apache.org/confluence/display/KAFKA/KIP-320%3A+Allow+fetchers+to+detect+and+handle+log+truncation): @@ -19,7 +30,7 @@ confluent-kafka-go is based on librdkafka v2.1.0, see the [librdkafka v2.1.0 release notes](https://github.com/confluentinc/librdkafka/releases/tag/v2.1.0) -and later ones for a complete list of changes, enhancements, fixes and upgrade considerations. +for a complete list of changes, enhancements, fixes and upgrade considerations. ## v2.0.2 diff --git a/examples/go.mod b/examples/go.mod index 5c3ba2ae8..6888eae4b 100644 --- a/examples/go.mod +++ b/examples/go.mod @@ -8,7 +8,7 @@ require ( github.com/actgardner/gogen-avro/v10 v10.2.1 github.com/alecthomas/kingpin v2.2.6+incompatible github.com/alecthomas/units v0.0.0-20211218093645-b94a6e3cc137 // indirect - github.com/confluentinc/confluent-kafka-go/v2 v2.1.0 + github.com/confluentinc/confluent-kafka-go/v2 v2.1.1-RC1 github.com/gdamore/tcell v1.4.0 google.golang.org/protobuf v1.30.0 ) diff --git a/kafka/api.html b/kafka/api.html index 5c0efda2e..88d48db5e 100644 --- a/kafka/api.html +++ b/kafka/api.html @@ -1560,73 +1560,73 @@

- + 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 - + testhelpers.go - + time.go @@ -1757,7 +1757,7 @@

LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client

- 
const LibrdkafkaLinkInfo = "static glibc_linux_amd64 from librdkafka-static-bundle-v2.1.0.tgz"
+ 
const LibrdkafkaLinkInfo = "static glibc_linux_amd64 from librdkafka-static-bundle-v2.1.1-RC1.tgz"

OffsetBeginning represents the earliest offset (logical)

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

int

func - + ACLOperationFromString

+ String

+ ACLPermissionType 

int

func - + ACLPermissionTypeFromString

+ String

+ AdminClient

+ NewAdminClient

+ NewAdminClientFromConsumer

+ NewAdminClientFromProducer

+ AlterConfigs

+ AlterConsumerGroupOffsets

+ Close

+ ClusterID

+ ControllerID

+ CreateACLs

+ CreatePartitions

+ CreateTopics

+ DeleteACLs

+ DeleteConsumerGroups

+ DeleteTopics

+ DescribeACLs

+ DescribeConfigs

+ DescribeConsumerGroups

+ GetMetadata

+ IsClosed

+ ListConsumerGroupOffsets

+ ListConsumerGroups

+ SetOAuthBearerToken

+ SetOAuthBearerTokenFailure

+ SetSaslCredentials

+ String

+ AdminOption

+ AdminOptionMatchConsumerGroupStates

+ SetAdminMatchConsumerGroupStates

+ AdminOptionOperationTimeout

+ SetAdminOperationTimeout

+ AdminOptionRequestTimeout

+ SetAdminRequestTimeout

+ AdminOptionRequireStableOffsets

+ SetAdminRequireStableOffsets

+ AdminOptionValidateOnly

+ SetAdminValidateOnly

+ AlterConfigsAdminOption

+ AlterConsumerGroupOffsetsAdminOption

+ AlterConsumerGroupOffsetsResult

+ AlterOperation 

int

func (AlterOperation) - + String

+ AssignedPartitions

+ String 

AssignedPartitions) String() string

type - + BrokerMetadata

+ ConfigEntry

+ StringMapToConfigEntries

+ String

+ ConfigEntryResult

+ String

+ ConfigMap 

string]ConfigValue

func (ConfigMap) - + Get

+ Set

+ SetKey

+ ConfigResource

+ String

+ ConfigResourceResult

+ String

+ ConfigSource 

int

func (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 

int

func - + ConsumerGroupStateFromString

+ String

+ ConsumerGroupTopicPartitions

+ String 

ConsumerGroupTopicPartitions) String() string

type - + CreateACLResult

+ CreateACLsAdminOption

+ CreatePartitionsAdminOption

+ CreateTopicsAdminOption

+ DeleteACLsAdminOption

+ DeleteACLsResult 

DescribeACLsResult

type - + DeleteConsumerGroupsAdminOption

+ DeleteConsumerGroupsResult

+ DeleteTopicsAdminOption

+ DescribeACLsAdminOption

+ DescribeACLsResult

+ DescribeConfigsAdminOption

+ DescribeConsumerGroupsAdminOption

+ DescribeConsumerGroupsResult

+ Error

+ NewError

+ Code

+ Error

+ IsFatal

+ IsRetriable

+ IsTimeout

+ String

+ TxnRequiresAbort

+ ErrorCode

+ String

+ Event

+ Handle