Execution failed for task ':extensions-kafka:spotlessJavaCheck'. > The following files had format violations: src/main/java/io/deephaven/kafka/ingest/ConsumerRecordToStreamPublisherAdapter.java @@ -27,7 +27,7 @@ ·····*·Consume·a·List·of·Kafka·records,·producing·zero·or·more·rows·in·the·output. ·····* ·····*·@param·receiveTime·the·time,·in·nanoseconds·since·the·epoch,·the·records·were·received·in·this·process -·····*·@param·records··the·records·received·from·{@link·org.apache.kafka.clients.consumer.KafkaConsumer#poll(Duration)}. +·····*·@param·records·the·records·received·from·{@link·org.apache.kafka.clients.consumer.KafkaConsumer#poll(Duration)}. ·····*·@return·the·number·of·bytes·processed ·····*·@throws·IOException·if·there·was·an·error·writing·to·the·output·table ·····*/ src/main/java/io/deephaven/kafka/ingest/KafkaRecordConsumer.java @@ -19,11 +19,11 @@ ·····*·Consume·a·list·of·ConsumerRecords·coming·from·Kafka. ·····* ·····*·@param·receiveTime·the·time,·in·nanoseconds·since·the·epoch,·the·records·were·received·in·this·process -·····*·@param·records··the·records·to·consume +·····*·@param·records·the·records·to·consume ·····*·@return·the·total·number·of·message·bytes·processed,·according·whether·any·key·and/or·value·fields·were -·····*·processed,·and·the·corresponding·values·for -·····*·{@code·org.apache.kafka.clients.consumer.ConsumerRecord.serializedKeySize} -·····*·{@code·org.apache.kafka.clients.consumer.ConsumerRecord.serializedValueSize} +·····*·········processed,·and·the·corresponding·values·for +·····*·········{@code·org.apache.kafka.clients.consumer.ConsumerRecord.serializedKeySize} +·····*·········{@code·org.apache.kafka.clients.consumer.ConsumerRecord.serializedValueSize} ·····*/ ····long·consume(long·receiveTime,·@NotNull·List<?·extends·ConsumerRecord<?,·?>>·records); } src/main/java/io/deephaven/kafka/ingest/KafkaStreamPublisher.java @@ -172,7 +172,8 @@ ····} ····@OverRide -····public·synchronized·long·consumeRecords(long·receiveTime,·@NotNull·final·List<?·extends·ConsumerRecord<?,·?>>·records)·{ +····public·synchronized·long·consumeRecords(long·receiveTime, +············@NotNull·final·List<?·extends·ConsumerRecord<?,·?>>·records)·{ ········WritableChunk<Values>[]·chunks·=·getChunksToFill(); ········checkChunkSizes(chunks); ········int·remaining·=·chunks[0].capacity()·-·chunks[0].size(); Run './gradlew :extensions-kafka:spotlessApply' to fix these violations.