fix nits

Signed-off-by: Antonio Pedro <[email protected]>

Author: antonio-pedro99

src/main/java/io/strimzi/kafka/bridge/http/converter/HttpJsonMessageConverter.java

@@ -75,7 +75,7 @@ public List<ProducerRecord<byte[], byte[]>> toKafkaRecords(String kafkaTopic, In
         JsonNode json = JsonUtils.bytesToJson(messages);
         ArrayNode jsonArray = (ArrayNode) json.get("records");
 
-        for (JsonNode jsonObj : jsonArray) {
+        for (JsonNode jsonObj: jsonArray) {
             records.add(toKafkaRecord(kafkaTopic, partition, JsonUtils.jsonToBytes(jsonObj)));
         }
         return records;
@@ -106,7 +106,7 @@ public byte[] toMessages(ConsumerRecords<byte[], byte[]> records) {
 
             ArrayNode headers = JsonUtils.createArrayNode();
 
-            for (Header kafkaHeader : record.headers()) {
+            for (Header kafkaHeader: record.headers()) {
                 ObjectNode header = JsonUtils.createObjectNode();
 
                 header.put("key", kafkaHeader.key());

src/test/java/io/strimzi/kafka/bridge/http/ProducerIT.java

@@ -107,6 +107,7 @@ void sendSimpleMessageToPartition(VertxTestContext context) throws InterruptedEx
         KafkaFuture<Void> future = adminClientFacade.createTopic(topic, 2, 1);
 
         String value = "message-value";
+
         int partition = 1;
 
         JsonArray records = new JsonArray();
@@ -208,7 +209,6 @@ void sendSimpleMessageWithKey(VertxTestContext context) throws InterruptedExcept
         KafkaFuture<Void> future = adminClientFacade.createTopic(topic, 2, 1);
 
         String value = "message-value";
-
         String key = "my-key";
 
         JsonArray records = new JsonArray();