This is an automated email from the ASF dual-hosted git repository.
tallison pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/tika.git
The following commit(s) were added to refs/heads/main by this push:
new 9bff3161f checkstyle fixes for #616
9bff3161f is described below
commit 9bff3161f92058e0653835806e59360fafb9077c
Author: tallison <[email protected]>
AuthorDate: Mon Jul 25 13:19:57 2022 -0400
checkstyle fixes for #616
---
.../org/apache/tika/pipes/emitter/kafka/KafkaEmitter.java | 11 +++++++----
.../tika/pipes/pipesiterator/kafka/KafkaPipesIterator.java | 11 +++++++----
.../pipes/pipesiterator/kafka/TestKafkaPipesIterator.java | 5 +++--
3 files changed, 17 insertions(+), 10 deletions(-)
diff --git
a/tika-pipes/tika-emitters/tika-emitter-kafka/src/main/java/org/apache/tika/pipes/emitter/kafka/KafkaEmitter.java
b/tika-pipes/tika-emitters/tika-emitter-kafka/src/main/java/org/apache/tika/pipes/emitter/kafka/KafkaEmitter.java
index aeee40049..4076e7a40 100644
---
a/tika-pipes/tika-emitters/tika-emitter-kafka/src/main/java/org/apache/tika/pipes/emitter/kafka/KafkaEmitter.java
+++
b/tika-pipes/tika-emitters/tika-emitter-kafka/src/main/java/org/apache/tika/pipes/emitter/kafka/KafkaEmitter.java
@@ -30,6 +30,9 @@ import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.StringSerializer;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
import org.apache.tika.config.Field;
import org.apache.tika.config.Initializable;
import org.apache.tika.config.InitializableProblemHandler;
@@ -38,8 +41,6 @@ import org.apache.tika.exception.TikaConfigException;
import org.apache.tika.metadata.Metadata;
import org.apache.tika.pipes.emitter.AbstractEmitter;
import org.apache.tika.pipes.emitter.TikaEmitterException;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
/**
* Emits the now-parsed documents into a specified Apache Kafka topic.
@@ -259,8 +260,10 @@ public class KafkaEmitter extends AbstractEmitter
implements Initializable {
safePut(props, ProducerConfig.TRANSACTION_TIMEOUT_CONFIG,
transactionTimeoutMs);
safePut(props, ProducerConfig.TRANSACTIONAL_ID_CONFIG,
transactionalId);
- safePut(props, ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
serializerClass(keySerializer, StringSerializer.class));
- safePut(props, ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
serializerClass(valueSerializer, StringSerializer.class));
+ safePut(props, ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
+ serializerClass(keySerializer, StringSerializer.class));
+ safePut(props, ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
+ serializerClass(valueSerializer, StringSerializer.class));
producer = new KafkaProducer<>(props);
}
diff --git
a/tika-pipes/tika-pipes-iterators/tika-pipes-iterator-kafka/src/main/java/org/apache/tika/pipes/pipesiterator/kafka/KafkaPipesIterator.java
b/tika-pipes/tika-pipes-iterators/tika-pipes-iterator-kafka/src/main/java/org/apache/tika/pipes/pipesiterator/kafka/KafkaPipesIterator.java
index 5cb917144..19df4408f 100644
---
a/tika-pipes/tika-pipes-iterators/tika-pipes-iterator-kafka/src/main/java/org/apache/tika/pipes/pipesiterator/kafka/KafkaPipesIterator.java
+++
b/tika-pipes/tika-pipes-iterators/tika-pipes-iterator-kafka/src/main/java/org/apache/tika/pipes/pipesiterator/kafka/KafkaPipesIterator.java
@@ -27,6 +27,9 @@ import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.common.serialization.StringDeserializer;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
import org.apache.tika.config.Field;
import org.apache.tika.config.Initializable;
import org.apache.tika.config.InitializableProblemHandler;
@@ -39,8 +42,6 @@ import org.apache.tika.pipes.HandlerConfig;
import org.apache.tika.pipes.emitter.EmitKey;
import org.apache.tika.pipes.fetcher.FetchKey;
import org.apache.tika.pipes.pipesiterator.PipesIterator;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
public class KafkaPipesIterator extends PipesIterator implements Initializable
{
@@ -119,8 +120,10 @@ public class KafkaPipesIterator extends PipesIterator
implements Initializable {
public void initialize(Map<String, Param> params) {
props = new Properties();
safePut(props, ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,
bootstrapServers);
- safePut(props, ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,
serializerClass(keySerializer, StringDeserializer.class));
- safePut(props, ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,
serializerClass(valueSerializer, StringDeserializer.class));
+ safePut(props, ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,
+ serializerClass(keySerializer, StringDeserializer.class));
+ safePut(props, ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,
+ serializerClass(valueSerializer, StringDeserializer.class));
safePut(props, ConsumerConfig.GROUP_ID_CONFIG, groupId);
safePut(props, ConsumerConfig.AUTO_OFFSET_RESET_CONFIG,
autoOffsetReset);
safePut(props, "group.inital.rebalance.delay.ms",
groupInitialRebalanceDelayMs);
diff --git
a/tika-pipes/tika-pipes-iterators/tika-pipes-iterator-kafka/src/test/java/org/apache/tika/pipes/pipesiterator/kafka/TestKafkaPipesIterator.java
b/tika-pipes/tika-pipes-iterators/tika-pipes-iterator-kafka/src/test/java/org/apache/tika/pipes/pipesiterator/kafka/TestKafkaPipesIterator.java
index 152c5101b..4b83d9647 100644
---
a/tika-pipes/tika-pipes-iterators/tika-pipes-iterator-kafka/src/test/java/org/apache/tika/pipes/pipesiterator/kafka/TestKafkaPipesIterator.java
+++
b/tika-pipes/tika-pipes-iterators/tika-pipes-iterator-kafka/src/test/java/org/apache/tika/pipes/pipesiterator/kafka/TestKafkaPipesIterator.java
@@ -29,11 +29,12 @@ import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
-import org.apache.tika.pipes.FetchEmitTuple;
-import org.apache.tika.pipes.pipesiterator.PipesIterator;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
+import org.apache.tika.pipes.FetchEmitTuple;
+import org.apache.tika.pipes.pipesiterator.PipesIterator;
+
@Disabled("turn into an actual unit test")
public class TestKafkaPipesIterator {
