Jiaqi Shen

[Issue 456] Support chunking for big messages.

2

### Contribution Checklist Master Issue: [#456](https://github.com/apache/pulsar-client-go/issues/456) ### Motivation Make pulsar go client support chunking to produce/consume big messages. The earlier implementation ([#717](https://github.com/apache/pulsar-client-go/pull/717)) didn't take into account many details, so I...

[fix][client] Fix the blocked producer due to chunking when blockIfQueueFull is enabled

2

Fixes #17446 ### Motivation Producer may be permanently blocked by chunking messages when blockIfQueueFull is enabled. The reason for this bug is how the chunk message semaphore is acquired. https://github.com/apache/pulsar/blob/359cfa7bc05775bf6dd004f21b9907610ed3b3d5/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java#L520-L527...

[BUG] The capacity of dataChan is too big

2

Hi community. I noticed that the capacity of dataChan is too big. We make the `dataChan` with capacity `MaxPendingMessages` and the account of pending messages actual in queue may exceed...

The behavior of `Seek` is different with Java Client

2

Hi all, I noticed that the behavior of go client `Seek` is different with Java client, which may confuse the users. For exmaple, when `Seek()` invoked. ``` java // Java...

In the panel pulsar-topics, the query for cluster/namespace/topic may hang prometheus. https://github.com/streamnative/apache-pulsar-grafana-dashboard/blob/abf90c1e60fd10c32752ed4f0f7cefe940623cd3/dashboards/topic.json#L1095 https://github.com/streamnative/apache-pulsar-grafana-dashboard/blob/abf90c1e60fd10c32752ed4f0f7cefe940623cd3/dashboards/topic.json#L1115 https://github.com/streamnative/apache-pulsar-grafana-dashboard/blob/abf90c1e60fd10c32752ed4f0f7cefe940623cd3/dashboards/topic.json#L1075 It will query all the metrics to find all the cluster/namespace/topics, which may cause prometheus crash.

Hi, when I implemented W1D5, I found that my code can not pass `test_task2_storage_scan()`. It is caused by wrong result returned by `sst.first_key()` and `sst.last_key()` because of my missing in...

"two" things -> "three" things https://github.com/skyzh/mini-lsm/blob/bcaab6f706cb33ebaea6a1f00c444f84d924f309/mini-lsm-book/src/week1-06-write-path.md?plain=1#L29-L33

Should function signatures be consistent between mini-lsm-starter and mini-lsm?

1

Hi, I noticed that some function signatures is different beween mini-lsm-starter and mini-lsm. For example, `decode_block_meta` in mini-lsm-starter https://github.com/skyzh/mini-lsm/blob/bcaab6f706cb33ebaea6a1f00c444f84d924f309/mini-lsm-starter/src/table.rs#L45-L47 `decode_block_meta` in mini-lsm https://github.com/skyzh/mini-lsm/blob/bcaab6f706cb33ebaea6a1f00c444f84d924f309/mini-lsm/src/table.rs#L64-L66 According to the commit history, it seems...