apache / apache/pulsar-client-python

[Feature request] Expose expireTimeOfIncompleteChunkedMessageMs to the Consumer

未關閉
#141 0 則留言 0 個 reaction 已指派 0 人 在 GitHub 檢視
主要語言
Python
星號
75
分支
53
PR 合併指標
30 天內沒有已合併 PR

描述

# Motivation
Two of the three message chunking related settings in the ConsumerConfiguration have already been exposed to the consumer. Namely, maxPendingChunkedMessage and autoAckOldestChunkedMessageOnQueueFull. However, the third one, expireTimeOfIncompleteChunkedMessageMs, has not yet been exposed. If this third one can be exposed then the python client consumer would have full control over how they want to handle chunked messages.

TLDR: Expose expireTimeOfIncompleteChunkedMessageMs of the ConsumerConfiguration to the consumer, which can be found here: https://github.com/apache/pulsar-client-cpp/blob/1e7d259bb94379ef6e4618fdac283912d0be6861/lib/ConsumerConfigurationImpl.h#L61.

貢獻指南

開啟貢獻指南

研究方向

首先比較 maxPendingChunkedMessage 和 autoAckOldestChunkedMessageOnQueueFull 在 Python consumer 中的暴露方式,然後追蹤 ConsumerConfigurationImpl.h 中對應的設定。當 expireTimeOfIncompleteChunkedMessageMs 可供 Python consumer 使用,並能對未完成的 Chunk 訊息進行等效控制時,即視為完成。

由索引模型根據 Issue 內容生成。

評估

技術堆疊
cpp, python
領域
backend-api-design, distributed-systems
Issue 類型
功能
難度
4/5
預估耗時
3-5 天
活躍度
停滯
描述清晰度
基本清楚
新手友好度
45/100

把新 issue 寄到你的電子郵件信箱

精選適合新手參與的 GitHub issue 摘要。