Gimi Liang

Hi @0xa48rx394r83e9, sorry for the late reponse. I would suggest to put all iceberg related code in `src/Storages/ExternalTable/Iceberg` for now, we can relocate the code whenever we need to in...

In fact, this issue also applies to MVs which use a target stream, no matter if that target stream is an external stream, a Proton stream, or an external table....

> proxy to the pointed target stream is consistent in all cases and makes more sense vs throw exception for different cases to me. it is like a pointer, if...

> Then why user like to send all hot things to one target stream ? I am not sure if I understand your question. It's just an example, users can...

A consumer is bound to a specific topic parition ( using the legacy simpler consumer API ) or a specific list of paritions (using the new consumer API ). So,...

Hi @zhongyuankai , would you share your use case with a little bit more details? For example, do you have a big Kafka cluster that has lots of topics and...

This will be implemented exactly the same way as how `_tp_message_key` is implemented (in enterprise version) for writing: https://docs.timeplus.com/proton-kafka#messagekey . I.e. firstly, create an external stream with specifying the column...

Hi @mateng0915 , I created the stream and external stream as you described in the ticket, and everything works just fine for me. When did that error show up? Was...

I did a simple performance test: 1. Created a stream called `users`, and inserted 5 million records into it. Each row, after encoded into JSON, its is about 80 bytes,...

I have done another round a test with 1,000,000 records, and the records' sizes are around 1KiB ( something between 900 bytes to 1500 bytes ). The results are still...