KAFKA-20173: Propagate headers into serde 1/N

[UladzislauBlok]

Propagate headers into serializes / deserializers

This PR partially covers org.apache.kafka.streams.kstream package.

Code:

• Use empty headers for backward compatibility
• Propagate headers when it's possible

Tests:

• Use empty headers for existing tests
• Add new test if needed

Reviewers: Matthias J. Sax matthias@confluent.io, Alieh Saeedi
asaeedi@confluent.io, TengYao Chi frankvicky@apache.org

[UladzislauBlok]

@mjsax Hello.
First is ready to be review. Thanks

[mjsax]

Overall LGTM.

[mjsax]

Is the PR description correct?

This PR covers org.apache.kafka.streams.kstream package (without sub-packages)

Does this PR really cover the entire package?

[mjsax]

Build failed with checkstyle error:

Execution failed for task ':streams:spotlessJavaCheck'.
> The following files had format violations:
      src/test/java/org/apache/kafka/streams/kstream/SessionWindowedDeserializerTest.java
          @@ -24,8 +24,8 @@
           import·org.apache.kafka.common.serialization.Serdes;
           import·org.apache.kafka.common.serialization.StringDeserializer;
           import·org.apache.kafka.streams.StreamsConfig;
          +import·org.apache.kafka.streams.kstream.internals.TimeWindow;
           
          -import·org.apache.kafka.streams.kstream.internals.TimeWindow;
           import·org.junit.jupiter.api.Test;
           
           import·java.util.HashMap;
  Run './gradlew spotlessApply' to fix all violations.

[UladzislauBlok]

Is the PR description correct?

This PR covers org.apache.kafka.streams.kstream package (without sub-packages)

Does this PR really cover the entire package?

Thanks for checking. I found two more calls to serializer in this package (previously I checked only deserializer). They are from the same classes, so I'll add them

[aliehsaeedii]

Thanks for checking. I found two more calls to serializer in this package (previously I checked only deserializer). They are from the same classes, so I'll add them

not sure about the scope of the change. Should we consider the deserializer in FullChangeSerde.java, CombinedKeySchema.java, ... and many more calls of .deserialize(topic, data) in the package?

Oh, OK, you said (without sub-packages). A short explanation of the reason for this scope could be added maybe.

[frankvicky]

Overall LGTM
Please run ./gradlew spotlessApply to fix the CI.

[UladzislauBlok]

@mjsax @aliehsaeedii
I found out that my initial approach to finding all locations needing fixes was incorrect (I was checking all calls to serialize/deserialize methods). There are still a few places in the org.apache.kafka.streams.kstream package to address. Since this PR has already been reviewed, I would merge it now and address the remaining places in follow-up PRs. Description was changed accordingly

[frankvicky]

@UladzislauBlok Thanks for the PR, merged.