public ByTopicRecordTranslator<K, V> forTopic(String topic, Func<ConsumerRecord<K, V>, List<Object>> func, Fields fields) {
        return forTopic(topic, new SimpleRecordTranslator<>(func, fields));
    }
@Test
    public void testFieldCollision() {
        assertThrows(IllegalArgumentException.class, () -> {
            ByTopicRecordTranslator<String, String> trans =
                new ByTopicRecordTranslator<>((r) -> new Values(r.key()), new Fields("key"));
            trans.forTopic("foo", (r) -> new Values(r.value()), new Fields("value"));
        });
    }