Bohan Zhang

we can allow user-defined parts only when both name and type are matched with the ones mapped from avro/pb. Let's take another look, cc @st1page

> each of the first three options has its corresponding API for reading in credential content, which is listed as follows: > > 1. `properties.ssl.ca.location` > -> > `ssl.ca.pem` >...

Hi @kazdy, thanks for contribution. There are two auth for MSK, SSL/SASL and IAM (AWS recommends). * SSL/SASL requires `SCRAM-SHA-512` as you mentioned [ref](https://docs.aws.amazon.com/msk/latest/developerguide/msk-password-limitations.html). * IAM auth allows RisingWave loads...

> Also I don't think this line is correct, it mentions Kinesis, but this page is about Kafka: > > https://github.com/risingwavelabs/risingwave-docs/blob/55859598972ebb2e5d92dc7b6e76a2250f62e147/integrations/sources/amazon-msk.mdx?plain=1#L212 > > For kafka we use brokers and not...

 Their diagram tells the story. Subject Mapping does things inside broker, you can dynamically route messages into different subjects. RW, on the consumer side, does not need to care...

> I am still confuse about one point: > > > The broker will dispatch messages across workers without a guarantee of the distribution. > > If we have several...

> @tabVersion is this finished? :) Not yet, we need another table def and sql. Let me mark as draft for now.

it may involve compatibility issue for users using upsert format before we introducing `include` clause. May need further investigation.

> Recently a user asked about the following use case: > > ```sql > create table raw_data ( > ts timestamp, > foo int, > bar int > ); >...

> It will be great if we RW can know about if it's a test environment. We need a test encryption key for secret manger or we need to pass...