...

Changes to public interfaces:

org.apache.kafka.common.record.KafkaLZ4BlockInputStream

• add ignoreFlagDescriptorChecksum boolean
  • constructor interface to configure
  • ignoreFlagDescriptorChecksum() public getter
    
  • when set, decompression will not validate the header checksum

org.apache.kafka.common.record.KafkaLZ4BlockOutputStream

...

• constructor interface to configure
• useBrokenFlagDescriptorChecksum() public getter
• when set, compression writes header checksum using old method (include magic bytes)

...

Interface classes are for classes not currently marked as public in javadoc.

Proposed Changes

Old 0.8.2/0.9 clients (current behavior):

...