If table id is changed, sender will send request to wrong bucket.

[loserwang1024]

Search before asking

• I searched in the issues and found nothing similar.

Fluss version

0.8.0 (latest release)

Please describe the bug 🐞

Currently, RecordAccumulator#getReadyDeque is based on (table name , parititon name, bucket id). However , if a table a(table id = 1) is removed, and recreate a new table aslo named a(table id = 2) , then old request for old table will be sent to new table.

Then the ProduceLogRequest will be set as wrong table id = 2.

Solution

Before sent , check whether table id is changed.

Are you willing to submit a PR?

• I'm willing to submit a PR!