Versions Compared


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


Current stateUnder Discussion

Discussion thread


Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).


Code Block
interface BrokerRecordValidator {
     * Validate the record for a given topic-partition.
	Optional<ApiRecordError>Optional<InvalidRecordException> validateRecord(Record record, TopicPartition topicPartitionTopicPartition topicPartition, ByteBuffer key, ByteBuffer value, Header[] headers);

Proposed Changes

The chain of validations would be called in the LogValidator.scala class' validateRecord(), right after the calls to validateKey() and validateTimestamp().
The return type Optional<ApiRecordError> is the same as the other internal validate functions are returning as of today.

Here is the proposed place in the existing code: