Skip to content

Commit

Permalink
style: remove checkstyle errors
Browse files Browse the repository at this point in the history
  • Loading branch information
aliehsaeedii committed Nov 4, 2022
1 parent 1728f4f commit 03355ec
Showing 1 changed file with 4 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@
import java.util.List;
import java.util.Map;
import java.util.Objects;
import org.apache.kafka.common.protocol.types.Field.Str;
import org.apache.kafka.connect.data.Date;
import org.apache.kafka.connect.data.Field;
import org.apache.kafka.connect.data.Schema;
Expand Down Expand Up @@ -249,13 +248,13 @@ private Object toKsqlValue(
}
}

private String structToString(Struct input) {
StringBuilder sb = new StringBuilder("{");
private String structToString(final Struct input) {
final StringBuilder sb = new StringBuilder("{");
boolean first = true;
List<Field> fields = input.schema().fields();
final List<Field> fields = input.schema().fields();

for (Field field : fields) {
Object value = input.get(field);
final Object value = input.get(field);
if (value != null) {
if (first) {
first = false;
Expand Down

0 comments on commit 03355ec

Please sign in to comment.