This Confluence has been LDAP enabled, if you are an ASF Committer, please use your LDAP Credentials to login. Any problems file an INFRA jira ticket please.

Child pages
  • KIP 141 - ProducerRecord & SourceRecord: Add timestamp constructors

Versions Compared


  • This line was added.
  • This line was removed.
  • Formatting was changed.


This KIP adds the missing constructor to add a Timestamp to a ProducerRecord or a SourceRecord. 

Public Interfaces

The ProducerRecord constructors will all be deprecated, except the main long explicit one:

New interface:

public SourceRecord(Map<String, ?> sourcePartition, Map<String, ?> sourceOffset,
 String topic, Schema valueSchema, Object value, Long timestamp)