Apache Kafka Rebalance Listener & Implementing a database sink for Kafka

[@rajukomaturi4341]

Thanks for the lecture , could you please provide code with database?

[@chenguo8767]

Thanks for the lecture. Just curious, what if we just set some rule on the database, if an record exists, ignore the update. In this way, even kafka reprocessing the same message, database will not be affected. what are the advantages of using rebalance listener in this case? Thank you!

[@shreyas-s5g]

watch partition assignor [ roundrobin,range type...] videos of same playlist, you will get idea. BTW rebalance listener class is used for revoking and assigning of partitions to consumers.