mindol1004/spring-boot-rest
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

BAEL3889 - Adding braces in EvenOddPartitioner

Browse Source
This commit is contained in:
Chirag Dewan
2020-06-07 15:29:59 +05:30
parent d79f6ec8a7
commit 68c0e90d0d
3 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
libraries-data-2/src/main/java/com/baeldung/kafka/producer/EvenOddPartitioner.java
View File

@@ -1,4 +1,4 @@
package com.baeldung.kafka; package com.baeldung.kafka.producer;
import org.apache.kafka.clients.producer.internals.DefaultPartitioner; import org.apache.kafka.clients.producer.internals.DefaultPartitioner;
import org.apache.kafka.common.Cluster; import org.apache.kafka.common.Cluster;
@@ -8,8 +8,9 @@ public class EvenOddPartitioner extends DefaultPartitioner {
@Override @Override
public int partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, Cluster cluster) { public int partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, Cluster cluster) {
if (((String)key).length() % 2 == 0) if (((String) key).length() % 2 == 0) {
return 0; return 0;
}
return 1; return 1;
} }

2
libraries-data-2/src/main/java/com/baeldung/kafka/producer/KafkaProducer.java
View File

@@ -1,4 +1,4 @@
package com.baeldung.kafka; package com.baeldung.kafka.producer;
import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerRecord; import org.apache.kafka.clients.producer.ProducerRecord;

4
libraries-data-2/src/test/java/com/baeldung/kafka/producer/KafkaProducerUnitTest.java
View File

@@ -1,5 +1,7 @@
package com.baeldung.kafka; package com.baeldung.kafka.producer;
import com.baeldung.kafka.producer.EvenOddPartitioner;
import com.baeldung.kafka.producer.KafkaProducer;
import org.apache.kafka.clients.producer.MockProducer; import org.apache.kafka.clients.producer.MockProducer;
import org.apache.kafka.clients.producer.RecordMetadata; import org.apache.kafka.clients.producer.RecordMetadata;
import org.apache.kafka.common.Cluster; import org.apache.kafka.common.Cluster;