You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2023/03/03 01:29:20 UTC

[GitHub] [pulsar] startjava edited a discussion: use "BacklogQuota.RetentionPolicy.producer_request_hold;"，sendTimeout exceeded(no ack) ,but producer always retry send message！

GitHub user startjava edited a discussion: use "BacklogQuota.RetentionPolicy.producer_request_hold;"，sendTimeout exceeded(no ack) ,but producer always retry send message！

                // long sizeLimit = 2147483648L;/
                long sizeLimit = 50000L;// 50KB
                int timeLimit = -1;/
                BacklogQuota.RetentionPolicy policy = BacklogQuota.RetentionPolicy.producer_request_hold;
                BacklogQuota quota = BacklogQuota.builder()
                        .limitSize(sizeLimit)
                        .limitTime(timeLimit)
                        .retentionPolicy(policy)
                        .build();
                admin.namespaces().setBacklogQuota(myTenant + "/" + myNameSpace3, quota);

GitHub link: https://github.com/apache/pulsar/discussions/19695

----
This is an automatically sent email for commits@pulsar.apache.org.
To unsubscribe, please send an email to: commits-unsubscribe@pulsar.apache.org