gfouquier opened a new issue #1967: non-persistent topic drop too much message URL: https://github.com/apache/incubator-pulsar/issues/1967 #### Expected behavior Messages sent to a non-persistent topic and acknowledge must be delivered, at least if the consumer is sufficient to prevent the broker from dropping. #### Actual behavior Only few messages are delivered to the consumer. With a persistent topic, all messages are delivered. With a non-persistent topic and pulsar 1.22, all messages are delivered. With pulsar 2.0 and a non-persistent topic, only a few messages are delivered (9/3000 in my simple experiment). The script is attach to this ticket. It doesn't need an installation of pulsar, a new archive is download and a standalone server is started. % PULSAR_VERSION=1.22.0-incubating PERS=non-persistent ./go.sh Pulsar version: 1.22.0-incubating Starting standalone pulsar with pid 15900 Starting pulsar consumer (pid 16309) on non-persistent://tenant/standalone/ns/topic Starting pulsar producer on non-persistent://tenant/standalone/ns/topic to send 1000 (foo bar baz) NB messages in consumer log: 1000 should be: 1000 Starting pulsar producer on non-persistent://tenant/standalone/ns/topic to send 1000 (foo bar baz) NB messages in consumer log: 2000 should be: 2000 Starting pulsar producer on non-persistent://tenant/standalone/ns/topic to send 1000 (foo bar baz) NB messages in consumer log: 3000 should be: 3000 % PULSAR_VERSION=2.0.0-rc1-incubating PERS=non-persistent ./go.sh Pulsar version: 2.0.0-rc1-incubating Starting standalone pulsar with pid 17091 Starting pulsar consumer (pid 17772) on non-persistent://tenant/ns/topic Starting pulsar producer on non-persistent://tenant/ns/topic to send 1000 (foo bar baz) NB messages in consumer log: 9 should be: 1000 Starting pulsar producer on non-persistent://tenant/ns/topic to send 1000 (foo bar baz) NB messages in consumer log: 9 should be: 2000 Starting pulsar producer on non-persistent://tenant/ns/topic to send 1000 (foo bar baz) NB messages in consumer log: 9 should be: 3000 % PULSAR_VERSION=2.0.0-rc1-incubating PERS=persistent ./test-pulsar.sh Pulsar version: 2.0.0-rc1-incubating Starting standalone pulsar with pid 22509 Starting pulsar consumer (pid 23199) on persistent://tenant/ns/topic Starting pulsar producer on persistent://tenant/ns/topic to send 1000 (foo bar baz) NB messages in consumer log: 1000 should be: 1000 Starting pulsar producer on persistent://tenant/ns/topic to send 1000 (foo bar baz) NB messages in consumer log: 2000 should be: 2000 Starting pulsar producer on persistent://tenant/ns/topic to send 1000 (foo bar baz) NB messages in consumer log: 3000 should be: 3000 #### Steps to reproduce 1. Using pulsar-client, launch a consumer on a non-persistent topic 2. Using pulsar-client, launch a producer on the same topic #### System configuration **Pulsar version**: 2.0.0-rc1-incubating [test-pulsar.sh.gz](https://github.com/apache/incubator-pulsar/files/2102633/test-pulsar.sh.gz)
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
