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;
  }
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...
no trespassing ...