Maziz MazizEsa

Someone who bricked a motherboard after flashing the wrong rom because of trying to OC an Intel Celeron from 400mhz to beyond 600mhz in 7th grade.

MazizEsa / incorrectcoupling.java

Last active November 8, 2020 22:40

Incorrect Coupling

	public class IncorrectCoupling {
	public static class Points{
	private String productId;
	private Long totalPoints;

	private PointsMappingExternalSystem pointsMappingExternalSystem;
	private PointsMultiplierExternalSystem pointsMultiplierExternalSystem;

	public Double calculateTotalPoints(){
	return pointsMappingExternalSystem.getPointsMappingFromExternalSystem().stream().map(PointsMapping::getPoints).reduce(0d, Double::sum)

MazizEsa / MethodIfElse.java

Created October 27, 2020 23:33

	public void exampleMinimizingIfElse() {
	final List<String> someExampleArray = new ArrayList<>();

	Optional.ofNullable(someExampleArray).orElse(Collections.emptyList()).forEach(this::doSomethingWithIt);

	ObjectUtils.defaultIfNull(someExampleArray, Collections.<String>emptyList()).forEach(this::doSomethingWithIt);

	returnEmptyArrayIfNecessary(someExampleArray).forEach(this::doSomethingWithIt);
	}

MazizEsa / VariableClarity.java

Created October 27, 2020 23:11

	public void buildThumbnailWithUrl() {
	final List<Thumbnail> rawThumbnailList = getThumbnailListFromSomeWhere();
	final String appropriateCdn = getTheRightCdnBasedOnRegion();
	final String defaultCdn = getDefaultCdn();

	final List<Thumbnail> thumbnailListWithCdn = rawThumbnailList.stream().map(eachThumbnail -> {
	final String cdnChose = eachThumbnail.isHasLarge() ? defaultCdn : appropriateCdn;
	eachThumbnail.setThumbnailUri(cdnChose + eachThumbnail.getThumbnailUri());
	return eachThumbnail;
	}).collect(Collectors.toList());

MazizEsa / methodAbstraction.java

Last active October 24, 2020 23:16

Method Abstraction Level

	public List<SomeDataFull> methodWithNoAbstraction() {
	// get data from DB for instance
	final List<SomeData> listOfDataFromDb = getDataFromDb(); // a.1

	final List<String> someDataRetrievedIds = listOfDataFromDb.stream().map(SomeData::getId).collect(Collectors.toList()); //a.2
	final Map<String, Boolean> someDataIdMapping = getVerificationFromExternalSystem(someDataRetrievedIds)
	.stream().collect(Collectors.toMap(SomeDataVerification::getId, SomeDataVerification::isOk));

	final List<SomeData> verifiedSomeData = listOfDataFromDb.stream().filter(eachData -> someDataIdMapping.getOrDefault(eachData.getId(), false)) //a.3
	.collect(Collectors.toList());

MazizEsa / application.yaml

Last active September 14, 2020 14:23

Producer application.yaml

	spring:
	kafka:
	bootstrap-servers: localhost:9092
	properties:
	schema.registry.url: http://localhost:8081
	producer:
	key-serializer: org.apache.kafka.common.serialization.StringSerializer
	value-serializer: io.confluent.kafka.serializers.KafkaAvroSerializer
	properties:
	value.subject.name.strategy: io.confluent.kafka.serializers.subject.RecordNameStrategy # so that the name of the subject will be derived from record name ie, org.maziz.something

MazizEsa / org.maz.schema.SplitSampleData.avsc

Last active September 14, 2020 13:39

Main Schema

MazizEsa / org.maz.schema.SplitEnumerationSample.avsc

Created September 14, 2020 13:37

The Custom Enum

	{
	"namespace": "org.maz.schema",
	"name": "SplitEnumerationSample",
	"type": "enum",
	"symbols": [
	"SAMPLE1",
	"SAMPLE2",
	"SAMPLE3"
	],
	"default": "SAMPLE1"

MazizEsa / org.maz.schema.FlatSampleData.avsc

Last active September 14, 2020 13:36

Flat Schema Source

MazizEsa / consumerpluginpom.xml

Last active September 15, 2020 12:26

Confluent Schema Maven Plugin Consumer with Schema Reference Example

	<plugin>
	<groupId>io.confluent</groupId>
	<artifactId>kafka-schema-registry-maven-plugin</artifactId>
	<version>${confluent.platform.version}</version>
	<executions>
	<execution>
	<phase>initialize</phase>
	<goals>
	<goal>download</goal>
	</goals>

MazizEsa / producerpluginpom.xml

Last active September 15, 2020 12:24

Confluent Schema Maven Plugin Producer with Schema Reference Example

	<plugin>
	<groupId>io.confluent</groupId>
	<artifactId>kafka-schema-registry-maven-plugin</artifactId>
	<version>${confluent.platform.version}</version>
	<executions>
	<execution>
	<phase>initialize</phase>
	<goals>
	<goal>register</goal>
	</goals>