- props.put("bootstrap.servers", properties.getBootstrapServer());
- props.put("group.id", properties.getGroupId());
- props.put("client.id", properties.getClientId());
- props.put("auto.offset.reset", properties.getAutoOffsetReset());
+ props.put("bootstrap.servers", properties.getConsumer().getBootstrapServers());
+ props.put("group.id", properties.getConsumer().getGroupId());
+ props.put("client.id", properties.getConsumer().getClientId());
+ props.put("auto.offset.reset", properties.getConsumer().getAutoOffsetReset());