Skip to content

Commit f22c13b

Browse files
committed
More precise description of the kafka timestamp.
1 parent f5bcbec commit f22c13b

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -169,7 +169,7 @@ public interface KafkaRecordBuilder {
169169
/**
170170
* Set the timestamp of the Kafka record.
171171
*
172-
* @param timestamp the value of the Kafka timestamp in milliseconds since UNIX epoch.
172+
* @param timestamp the value of the Kafka timestamp, in milliseconds since UNIX epoch.
173173
* @return this builder
174174
* @since 4.4.0
175175
*/

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ public interface KafkaRecord {
7474
@NotNull Optional<byte[]> getValueAsByteArray();
7575

7676
/**
77-
* @return an {@link Optional} of the timestamp of this record in milliseconds since UNIX epoch.
77+
* @return an {@link Optional} of the timestamp of this record, in milliseconds since UNIX epoch.
7878
* @since 4.4.0
7979
*/
8080
@NotNull Optional<Long> getTimestamp();

0 commit comments

Comments
 (0)