maprdb-protolib/src/main/java/com/streamsets/pipeline/stage/origin/cdc/maprdb/MapRDBCDCSource.java
private Properties getKafkaProperties() {
    Properties props = new Properties();
    props.putAll(conf.streamsOptions);

    props.setProperty("group.id", conf.consumerGroup);
    props.setProperty("max.poll.records", String.valueOf(batchSize));
    props.setProperty("enable.auto.commit", "true");
    props.setProperty("auto.commit.interval.ms", "1000");
    props.setProperty("key.deserializer", "org.apache.kafka.common.serialization.ByteArrayDeserializer");
    props.setProperty("value.deserializer", "com.mapr.db.cdc.ChangeDataRecordDeserializer");

    return props;
  }
private Properties getKafkaProperties() {
    Properties props = new Properties();
    props.putAll(conf.streamsOptions);

    props.setProperty("group.id", conf.consumerGroup);
    props.setProperty("max.poll.records", String.valueOf(batchSize));
    props.setProperty("enable.auto.commit", "true");
    props.setProperty("auto.commit.interval.ms", "1000");
    props.setProperty("key.deserializer", "org.apache.kafka.common.serialization.ByteArrayDeserializer");
    props.setProperty("value.deserializer", "com.mapr.db.cdc.ChangeDataRecordDeserializer");

    return props;
  }
no trespassing...