Skip to content
Snippets Groups Projects
Commit 15b82e83 authored by Lorenz Boguhn's avatar Lorenz Boguhn
Browse files

HazelcastJet: uc4 fix codestyle

parent ef8ce730
No related branches found
No related tags found
1 merge request!275Refactor hazelcast jet benchmarks:
......@@ -8,6 +8,11 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import titan.ccp.common.configuration.ServiceConfigurations;
/**
* Abstract HazelcastJetService.
* Holds common fields and logic shared for all hazelcast jet services.
* Set common settings and initiates a hazelcast jet instance.
*/
public abstract class HazelcastJetService {
private static final Logger LOGGER = LoggerFactory.getLogger(HazelcastJetService.class);
......
......@@ -17,14 +17,11 @@ public class KafkaPropertiesBuilder {
private static final String TRUE = "true";
private static final String AUTO_OFFSET_RESET_CONFIG = "earliest";
private final String specificAvroWriter = "specific.avro.writer";
private static final String SPECIFIC_AVRO_WRITER = "specific.avro.writer";
private Properties readProperties;
private final Properties readProperties;
private Properties writeProperties;
public KafkaPropertiesBuilder() {
}
private final Properties writeProperties;
/**
* Constructs a new PropertiesBuilder with defined default read and write properties.
......@@ -49,7 +46,7 @@ public class KafkaPropertiesBuilder {
readProperties.setProperty(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, AUTO_OFFSET_RESET_CONFIG);
readProperties.setProperty(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, TRUE);
writeProperties.setProperty(specificAvroWriter, TRUE);
writeProperties.setProperty(SPECIFIC_AVRO_WRITER, TRUE);
}
/**
......@@ -155,7 +152,7 @@ public class KafkaPropertiesBuilder {
props.setProperty(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
valueSerializer);
props.setProperty(AbstractKafkaAvroSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG, schemaRegistryUrl);
props.setProperty(specificAvroWriter, TRUE);
props.setProperty(SPECIFIC_AVRO_WRITER, TRUE);
return props;
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment