Going back to my previous comment... did you consider an interface like this:

`void insertFullMetrics(Collection<IMetric> metrics, MetricKindEnum kind) throws IOException`

ISTM that would be enough information to get data to either the right column family or kafka topic.