Skip to content

Commit f5bcbec

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

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-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.
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: 2 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;
@@ -73,7 +74,7 @@ public interface KafkaRecord {
7374
@NotNull Optional<byte[]> getValueAsByteArray();
7475

7576
/**
76-
* @return an {@link Optional} of the timestamp of this record.
77+
* @return an {@link Optional} of the timestamp of this record in milliseconds since UNIX epoch.
7778
* @since 4.4.0
7879
*/
7980
@NotNull Optional<Long> getTimestamp();

0 commit comments

Comments
 (0)