Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-4330: Fixed checkstyle violations (tabs instead of spaces). This closes #2185.

This commit is contained in:
Mark Payne 2017-09-29 10:33:38 -04:00
parent 2d5b8c7267
commit b3be2459e4
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerLease.java
View File

@ -423,7 +423,7 @@ public abstract class ConsumerLease implements Closeable, ConsumerRebalanceListe
} }
final byte[] value = record.value(); final byte[] value = record.value();
if (value != null) { if (value != null) {
out.write(record.value()); out.write(record.value());
} }
useDemarcator = true; useDemarcator = true;
} }
@ -447,8 +447,8 @@ public abstract class ConsumerLease implements Closeable, ConsumerRebalanceListe
FlowFile failureFlowFile = session.create(); FlowFile failureFlowFile = session.create();
final byte[] value = consumerRecord.value(); final byte[] value = consumerRecord.value();
if (value != null) { if (value != null) {
failureFlowFile = session.write(failureFlowFile, out -> out.write(value)); failureFlowFile = session.write(failureFlowFile, out -> out.write(value));
} }
failureFlowFile = session.putAllAttributes(failureFlowFile, attributes); failureFlowFile = session.putAllAttributes(failureFlowFile, attributes);
final String transitUri = KafkaProcessorUtils.buildTransitURI(securityProtocol, bootstrapServers, consumerRecord.topic()); final String transitUri = KafkaProcessorUtils.buildTransitURI(securityProtocol, bootstrapServers, consumerRecord.topic());

4
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerLease.java
View File

@ -441,7 +441,7 @@ public abstract class ConsumerLease implements Closeable, ConsumerRebalanceListe
} }
final byte[] value = record.value(); final byte[] value = record.value();
if (value != null) { if (value != null) {
out.write(record.value()); out.write(record.value());
} }
useDemarcator = true; useDemarcator = true;
} }
@ -468,7 +468,7 @@ public abstract class ConsumerLease implements Closeable, ConsumerRebalanceListe
final byte[] value = consumerRecord.value(); final byte[] value = consumerRecord.value();
if (value != null) { if (value != null) {
failureFlowFile = session.write(failureFlowFile, out -> out.write(value)); failureFlowFile = session.write(failureFlowFile, out -> out.write(value));
} }
failureFlowFile = session.putAllAttributes(failureFlowFile, attributes); failureFlowFile = session.putAllAttributes(failureFlowFile, attributes);

2
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerLease.java
View File

@ -392,7 +392,7 @@ public abstract class ConsumerLease implements Closeable, ConsumerRebalanceListe
} }
final byte[] value = record.value(); final byte[] value = record.value();
if (value != null) { if (value != null) {
out.write(record.value()); out.write(record.value());
} }
useDemarcator = true; useDemarcator = true;
} }