Skip to content

Commit 4820498

Browse files
committed
Addressed first round of CR requests.
1 parent 76998c3 commit 4820498

File tree

3 files changed

+6
-2
lines changed

3 files changed

+6
-2
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16+
1617
package com.hivemq.extensions.kafka.api.builders;
1718

1819
import com.hivemq.extension.sdk.api.annotations.NotNull;
@@ -185,6 +186,7 @@ public interface KafkaRecordBuilder {
185186
*
186187
* @return a new {@link KafkaRecord} containing a snapshot of the current state of this builder.
187188
* @throws NullPointerException if the topic was not set.
189+
* @since 4.4.0
188190
*/
189191
@NotNull KafkaRecord build();
190192
}

src/main/java/com/hivemq/extensions/kafka/api/model/KafkaCluster.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232
public interface KafkaCluster {
3333

3434
/**
35-
* @return the configured {@code <id>} of the luster.
35+
* @return the configured {@code <id>} of the cluster.
3636
* @since 4.4.0
3737
*/
3838
@NotNull String getId();

src/main/java/com/hivemq/extensions/kafka/api/model/KafkaHeaders.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16+
1617
package com.hivemq.extensions.kafka.api.model;
1718

1819
import com.hivemq.extension.sdk.api.annotations.DoNotImplement;
@@ -35,13 +36,14 @@ public interface KafkaHeaders {
3536

3637
/**
3738
* @return all Kafka headers as a {@link List}.
39+
* @since 4.4.0
3840
*/
3941
@Immutable @NotNull List<@NotNull KafkaHeader> asList();
4042

4143
/**
4244
* @param name the name of the Kafka header to get.
4345
* @return an {@link Optional} that contains the last Kafka header with the specified name.
44-
* @since 4.3.0
46+
* @since 4.4.0
4547
*/
4648
@NotNull Optional<KafkaHeader> getLast(@NotNull String name);
4749

0 commit comments

Comments
 (0)