Bot releases are hidden (Show)
Full Changelog: https://github.com/apache/pulsar-client-go/compare/v0.13.0...v0.13.1
Published by RobertIndie 3 months ago
github.com/linkedin/goavro/v2
to github.com/hamba/avro/v2
.pulsar.NewSchemaDefinition
has been removed. Use pulsar.NewAvroSchema
instead.omitempty
by @freeznet in https://github.com/apache/pulsar-client-go/pull/1185
HasNext
Function by @RobertIndie in https://github.com/apache/pulsar-client-go/pull/1182
VERSION
and stable.txt
files by @RobertIndie in https://github.com/apache/pulsar-client-go/pull/1158
SourceInstanceStatusData
in SinkInstanceStatus
by @jiangpengcheng in https://github.com/apache/pulsar-client-go/pull/1199
/
by @labuladong in https://github.com/apache/pulsar-client-go/pull/1229
ErrMaxConcurrentOpsReached
when too many concurrent ops in transaction coordinator client by @RobertIndie in https://github.com/apache/pulsar-client-go/pull/1242
Published by RobertIndie 8 months ago
HasNext
Function by @RobertIndie in #1182
Published by RobertIndie 9 months ago
Published by RobertIndie 12 months ago
SendAsync()
description by @Gleiphir2769 in #1066
DisableBatching=true
by @Gleiphir2769 in #1065
partitionProducer.Send()
is not performing as expected by @Gleiphir2769 in #1053
Full Changelog: https://github.com/apache/pulsar-client-go/compare/v0.11.0...v0.11.1-candidate-1
Published by RobertIndie over 1 year ago
GITHUB_TOKEN
in CI by @labuladong in https://github.com/apache/pulsar-client-go/pull/910
TestMaxPendingChunkMessages
by @Gleiphir2769 in https://github.com/apache/pulsar-client-go/pull/1003
negative_acks_tracker_test.go
by @RobertIndie in https://github.com/apache/pulsar-client-go/pull/1017
Full Changelog: https://github.com/apache/pulsar-client-go/compare/v0.10.0...v0.11.0
Published by RobertIndie over 1 year ago
reader
and improve test case by @labuladong in https://github.com/apache/pulsar-client-go/pull/889
consumer.go
by @sekfung in https://github.com/apache/pulsar-client-go/pull/857
time.Time{}
to uint64
by @aymkhalil in https://github.com/apache/pulsar-client-go/pull/865
DATA
constant as the prefix in OAuth2 KeyFileProvider by @Niennienzz in https://github.com/apache/pulsar-client-go/pull/866
clearMessageQueuesCh
in partitionConsumer.dispatcher()
by @Gleiphir2769 in https://github.com/apache/pulsar-client-go/pull/921
SeekByTime
by @Gleiphir2769 in https://github.com/apache/pulsar-client-go/pull/924
ProducerReady
is nil by @sekfung in https://github.com/apache/pulsar-client-go/pull/973
Published by wolfstudy about 2 years ago
goimports
-ed (goimports)) by @equanz in https://github.com/apache/pulsar-client-go/pull/824
test_helper.go
to follow the test code naming convention by @equanz in https://github.com/apache/pulsar-client-go/pull/822
Full Changelog: https://github.com/apache/pulsar-client-go/compare/v0.8.0...v0.9.0
Published by freeznet over 2 years ago
Full Changelog: https://github.com/apache/pulsar-client-go/compare/v0.8.0...v0.8.1
Published by wolfstudy over 2 years ago
oauth2
module by @reugn in https://github.com/apache/pulsar-client-go/pull/661
Full Changelog: https://github.com/apache/pulsar-client-go/compare/v0.7.0...v0.8.0-candidate-1
Published by cckellogg almost 3 years ago
Published by wolfstudy about 3 years ago
LedgerId,EntryId,BatchIdx,PartitionIdx
func for MessageId interface, see PR-529.Published by merlimat over 3 years ago
Published by wolfstudy over 3 years ago
import "C"
statement, see PR-416.Metrics.RpcRequestCount
to RPCRequestCount
to conform to style check, see PR-417.reader.HasNext()
returns true on empty topic, see PR-441.gogo/protobuf
to 1.3.2, see PR-446.logrusWrapper
shrink interfaces slice into an interface, see PR-449.KeyFileTypeServiceAccount
not found compile error, see PR-455.Published by wolfstudy almost 4 years ago
-1
, see PR-361.github.com/DataDog/zstd
with github.com/datadog/zstd
, see PR-385.Published by wolfstudy about 4 years ago
file://
and data://
, see PR-343.Published by wolfstudy over 4 years ago
Published by wolfstudy over 4 years ago
TLS
logicAuthentication
logicProxy
logicHostname verification
logicSend()
method in Producer
interfaceSendAsync()
method in Producer
interfaceLastSequenceID()
method in Producer
interfaceFlush()
method in Producer
interfaceClose()
method in Producer
interfaceTopic()
method in Producer
interfaceName()
method in Producer
interfaceMessageRouter
logicbatch
logiccompression message
logicHashingScheme
logicUser defined properties producer
logicSubscription()
method in Consumer
interfaceUnsubscribe()
method in Consumer
interfaceReceive()
method in Consumer
interfaceAck()
method in Consumer
interfaceAckID()
method in Consumer
interfaceNack()
method in Consumer
interfaceNackID()
method in Consumer
interfaceSeek()
method in Consumer
interfaceSeekByTime()
method in Consumer
interfaceClose()
method in Consumer
interfaceDead Letter Queue
consumer policyTopics Pattern
and Topics
logictopic consumer regx
logicmulti topics consumer
logicExclusive
, Failover
, Shared
and KeyShared
subscribe type logicLatest
and Earliest
logicReadCompacted
logicReplicateSubscriptionState
logicUser defined properties consumer
logicDelayed Delivery Messages
logicTopic()
method in Reader
interfaceNext()
method in Reader
interfaceHasNext()
method in Reader
interfaceClose()
method in Reader
interfaceread compacted
logicstart messageID
logicUser defined properties reader
logic