Hi Bertalan, Thanks for creating this KIP. A couple of observations/questions: 1. If I have multiple source->target pairs, can I set this property per cluster by prefixing with "source->target" as many other configs or is it global? 2. The replication policy must be set in MirrorClient as well. Is your change applicable to both MirrorClient and the connectors as well? 3. It might be worth pointing out (both in the docs and the KIP) that if the user overrides the replication policy to any other than DefaultReplicationPolicy, then this config has no effect. 4. With regards to integration tests, I tend to lean towards that we don't need them if we can cover this well with unit tests and mocking.
Thanks, Viktor On Wed, Jan 17, 2024 at 12:23 AM Ryanne Dolan <ryannedo...@gmail.com> wrote: > Makes sense to me, +1. > > On Tue, Jan 16, 2024 at 5:04 PM Kondrát Bertalan <kb.p...@gmail.com> > wrote: > >> Hey Team, >> >> I would like to start a discussion thread about the *KIP-1016 Make MM2 >> heartbeats topic name configurable >> < >> https://cwiki.apache.org/confluence/display/KAFKA/KIP-1016+Make+MM2+heartbeats+topic+name+configurable >> >* >> . >> >> This KIP aims to make the default heartbeat topic name (`heartbeats`) in >> the DefaultReplicationPolicy configurable via a property. >> Since this is my first KIP and the change is small, I implemented it in >> advance so, I can include the PR >> <https://github.com/apache/kafka/pull/15200> as well. >> >> I appreciate all your feedbacks and comments. >> >> Special thanks to Viktor Somogyi-Vass <viktor.somo...@cloudera.com> and >> Daniel >> Urban <urb.dani...@gmail.com> for the original idea and help. >> Thank you, >> Berci >> >> -- >> *Bertalan Kondrat* | Founder, SWE >> servy.hu <https://www.servy.hu/> >> >> >> >> <https://www.cloudera.com/> >> ------------------------------ >> >