This is an automated email from the ASF dual-hosted git repository.
mattisonchao pushed a change to branch codex/fix-consumer-ack-partition-lookup
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
from 01abfcf0 test: pass failure injection hook through consumer options
add 70ebd20f test: move failure injection hook to client
No new revisions were added by this update.
Summary of changes:
pulsar/client.go | 7 +++++++
pulsar/client_impl.go | 32 +++++++++++++++++---------------
pulsar/consumer.go | 7 -------
pulsar/consumer_impl.go | 4 ++--
pulsar/consumer_test.go | 10 +++++-----
5 files changed, 31 insertions(+), 29 deletions(-)