def make_replicator_config(topics, src_kafka, dest_kafka,
    topic_rename_format, tasks, schema_registry_topic, schema_registry_url,
    group_id, filter_regex, blacklist, check_interval):
    """Make Replicator connector configuration.

    Parameters
    ----------
    topics : `list`
        List of topics to whitelist.
    src_kafka : `str`
        Source Kafka broker.
    dest_kafka : `str`
        Destination kafka broker.
    topic_rename_format : `str`
        Format string for destination topics, e.g. `summit_$(topic)`.
    tasks : `int`
        Number of Kafka connect tasks.
    schema_registry_url : `str`
        Schema registry URL for the destination cluster.
    group_id : `str`
        Kafka Connect group.id
    filter_regex : `str`
        Regex of topics to replicate to the destination cluster.
    blacklist : `str`
        Topics to exclude from replication.
    check_interval : `int`
        How often to poll the source cluster for new topics.
    """
    DEFAULT_CONVERTER = (
        'io.confluent.connect.replicator.util.ByteArrayConverter')
    config = {}
    config['connector.class'
        ] = 'io.confluent.connect.replicator.ReplicatorSourceConnector'
    config['tasks.max'] = tasks
    config['key.converter'] = DEFAULT_CONVERTER
    config['value.converter'] = DEFAULT_CONVERTER
    config['header.converter'] = DEFAULT_CONVERTER
    config['schema.registry.topic'] = schema_registry_topic
    config['topic.regex'] = filter_regex
    topics = list(set(topics))
    topics.sort()
    topics.append(schema_registry_topic)
    if blacklist:
        config['topic.blacklist'] = ','.join(blacklist)
        for blacklisted_topic in blacklist:
            topics.remove(blacklisted_topic)
    config['topic.whitelist'] = ','.join(topics)
    config['topic.rename.format'] = topic_rename_format
    config['topic.poll.interval.ms'] = check_interval
    config['src.kafka.bootstrap.servers'] = src_kafka
    config['dest.kafka.bootstrap.servers'] = dest_kafka
    config['schema.subject.translator.class'
        ] = 'io.confluent.connect.replicator.schemas.DefaultSubjectTranslator'
    config['schema.registry.url'] = schema_registry_url
    if group_id:
        config['src.consumer.group.id'] = group_id
    return config
