Skip to content

[MONIT-3613] Update KafkaUtils to support prefixes for kafka topics

Guillermo Facundo Colunga requested to merge monit3613 into master

Moving to nile we have the need to add "monit-" prefix to all topics, for that a new parameter with default empty value is added to KafkaUtils class. If set, the value will be prepended to the existing topics, otherwise the existing topics will remain untouched. This is done at reading/writing time, so it should be transparent to the jobs, the only change would be to set the prefix when initializing the KafkaUtils class.

As it includes a minor change and still back-compatible with previous versions only the minor version has been increased.

Related JIRA ticket: https://its.cern.ch/jira/browse/MONIT-3613

Edited by Guillermo Facundo Colunga

Merge request reports