Skip to content

Commit 20ddeb2

Browse files
sauroterSgtSilvio
andcommitted
Apply suggestions from code review
Co-authored-by: Silvio Giebl <silvio.giebl@hivemq.com>
1 parent 81dceb5 commit 20ddeb2

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/com/hivemq/extensions/kafka/api/builders/KafkaRecordBuilder.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -101,7 +101,7 @@ public interface KafkaRecordBuilder {
101101
* @return this builder
102102
* @since 4.4.0
103103
*/
104-
@NotNull KafkaRecordBuilder value(@NotNull byte[] value);
104+
@NotNull KafkaRecordBuilder value(byte @NotNull [] value);
105105

106106
/**
107107
* Set the value of the Kafka record.
@@ -140,7 +140,7 @@ public interface KafkaRecordBuilder {
140140
* @return this builder
141141
* @since 4.4.0
142142
*/
143-
@NotNull KafkaRecordBuilder header(@NotNull String key, @NotNull byte[] value);
143+
@NotNull KafkaRecordBuilder header(@NotNull String key, byte @NotNull [] value);
144144

145145
/**
146146
* Add a header to the Kafka record.

0 commit comments

Comments
 (0)