Files

 master

/

pulsar

/

Copy path

Directory actions

More options

Directory actions

More options

Latest commit

zzzming

[issue 438] reader.HasNext() returns true on empty topic (apache#441)

Jan 15, 2021

2456729 · Jan 15, 2021

History

History

This branch is 631 commits behind apache/pulsar-client-go:master.

/

pulsar

/

Top

Folders and files

Name		Name	Last commit message	Last commit date
parent directory ..
internal		internal	Removed unused import "C" statement (apache#416)	Dec 14, 2020
log		log	define logger interface and add Logger field to ClientOptions (apache…	Oct 9, 2020
batcher_builder.go		batcher_builder.go	[Issue 172] Add key based batcher (apache#400)	Dec 1, 2020
client.go		client.go	Reduce the default TCP connection timeout from 30 to 5 seconds (apach…	Dec 12, 2020
client_impl.go		client_impl.go	Reduce the default TCP connection timeout from 30 to 5 seconds (apach…	Dec 12, 2020
client_impl_test.go		client_impl_test.go	[Issue 345] Add a new method to create auth provider from tls cert su…	Aug 17, 2020
consumer.go		consumer.go	Add schema logic in producer and consumer (apache#368)	Oct 23, 2020
consumer_impl.go		consumer_impl.go	deduplicate user topics before using them (apache#426)	Jan 4, 2021
consumer_interceptor.go		consumer_interceptor.go	[Issue 52]Add interceptor (apache#314)	Jul 14, 2020
consumer_multitopic.go		consumer_multitopic.go	fix retry policy not effective with partitioned topic (apache#425)	Jan 4, 2021
consumer_multitopic_test.go		consumer_multitopic_test.go	Enable golangci lint for project (apache#138)	Dec 27, 2019
consumer_partition.go		consumer_partition.go	fix leaked nack tracker goroutine (apache#418)	Dec 16, 2020
consumer_partition_test.go		consumer_partition_test.go	Attach topic and custom labels to Prometheus metrics (apache#410)	Dec 10, 2020
consumer_regex.go		consumer_regex.go	Attach topic and custom labels to Prometheus metrics (apache#410)	Dec 10, 2020
consumer_regex_test.go		consumer_regex_test.go	Fix deadlock when connection closed (apache#376)	Oct 9, 2020
consumer_test.go		consumer_test.go	fix retry policy not effective with partitioned topic (apache#425)	Jan 4, 2021
default_router.go		default_router.go	[Issue apache#401] Add orderingKey apis (apache#427)	Dec 23, 2020
default_router_bench_test.go		default_router_bench_test.go	Read the clock fewer times during message routing (apache#408)	Dec 2, 2020
default_router_test.go		default_router_test.go	Read the clock fewer times during message routing (apache#408)	Dec 2, 2020
dlq_router.go		dlq_router.go	[Issue apache#401] Add orderingKey apis (apache#427)	Dec 23, 2020
error.go		error.go	Enable golangci lint for project (apache#138)	Dec 27, 2019
helper.go		helper.go	Fix reconsume broken while using non-FQDN topics (apache#386)	Nov 5, 2020
helper_test.go		helper_test.go	Add metadata to produce and subscribe commands. (apache#117)	Dec 11, 2019
impl_message.go		impl_message.go	[issue 438] reader.HasNext() returns true on empty topic (apache#441)	Jan 15, 2021
impl_message_bench_test.go		impl_message_bench_test.go	Different MessageID implementations for message Production and Consum…	Jul 24, 2020
impl_message_test.go		impl_message_test.go	Different MessageID implementations for message Production and Consum…	Jul 24, 2020
key_shared_policy.go		key_shared_policy.go	consumer add key shared policy support (apache#363)	Oct 9, 2020
key_shared_policy_test.go		key_shared_policy_test.go	consumer add key shared policy support (apache#363)	Oct 9, 2020
message.go		message.go	[Issue apache#401] Add orderingKey apis (apache#427)	Dec 23, 2020
negative_acks_tracker.go		negative_acks_tracker.go	fix leaked nack tracker goroutine (apache#418)	Dec 16, 2020
negative_acks_tracker_test.go		negative_acks_tracker_test.go	fix leaked nack tracker goroutine (apache#418)	Dec 16, 2020
primitiveSerDe.go		primitiveSerDe.go	Add schema logic in producer and consumer (apache#368)	Oct 23, 2020
primitiveSerDe_test.go		primitiveSerDe_test.go	Add schema logic in producer and consumer (apache#368)	Oct 23, 2020
producer.go		producer.go	[Issue 172] Add key based batcher (apache#400)	Dec 1, 2020
producer_impl.go		producer_impl.go	Attach topic and custom labels to Prometheus metrics (apache#410)	Dec 10, 2020
producer_interceptor.go		producer_interceptor.go	[Issue 52]Add interceptor (apache#314)	Jul 14, 2020
producer_partition.go		producer_partition.go	[Issue apache#401] Add orderingKey apis (apache#427)	Dec 23, 2020
producer_test.go		producer_test.go	Support sendTimeout (apache#394)	Nov 30, 2020
reader.go		reader.go	Add seek logic for reader (apache#356)	Aug 24, 2020
reader_impl.go		reader_impl.go	[issue 438] reader.HasNext() returns true on empty topic (apache#441)	Jan 15, 2021
reader_test.go		reader_test.go	[issue 438] reader.HasNext() returns true on empty topic (apache#441)	Jan 15, 2021
retry_router.go		retry_router.go	define logger interface and add Logger field to ClientOptions (apache…	Oct 9, 2020
schema.go		schema.go	Add schema logic in producer and consumer (apache#368)	Oct 23, 2020
schema_def_test.go		schema_def_test.go	Add schema logic in producer and consumer (apache#368)	Oct 23, 2020
schema_test.go		schema_test.go	Add schema logic in producer and consumer (apache#368)	Oct 23, 2020
test_helper.go		test_helper.go	Auto update the client to handle changes in number of partitions (apa…	Apr 14, 2020
View all files