Thanks for ur solution, i have not planed to use Kafaka yet. And i already have a trigger in my code to invoke when document updated, which is not DCP. So maybe i will change to use DCP after do some benchmark testing.
My question is whether i use DCP or not, i still need a listener bucket to record data change information from origin bucket, so is there some better idea to just push/add data to listener bucket, and how to handle when this bucket is get bigger and bigger?