kafka git commit: KAFKA-4183; Corrected Kafka Connect's JSON Converter to properly convert from null to logical values

Repository: kafka Updated Branches: refs/heads/trunk 86aa0eb0f -> 567cc3d78 KAFKA-4183; Corrected Kafka Connect's JSON Converter to properly convert from null to logical values The `JsonConverter` class has `LogicalTypeConverter` implementations for Date, Time, Timestamp, and Decimal, but

kafka git commit: KAFKA-4173; SchemaProjector should successfully project missing Struct field when target field is optional

Repository: kafka Updated Branches: refs/heads/trunk 567cc3d78 -> d7bffebca KAFKA-4173; SchemaProjector should successfully project missing Struct field when target field is optional Author: Shikhar Bhushan Reviewers: Konstantine Karantasis ,

[3/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams

http://git-wip-us.apache.org/repos/asf/kafka/blob/86aa0eb0/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregateTest.java -- diff --git

[1/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams

Repository: kafka Updated Branches: refs/heads/trunk 143a33bc5 -> 86aa0eb0f http://git-wip-us.apache.org/repos/asf/kafka/blob/86aa0eb0/streams/src/test/java/org/apache/kafka/streams/state/internals/ThreadCacheTest.java -- diff

[6/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams

KAFKA-3776: Unify store and downstream caching in streams This is joint work between dguy and enothereska. The work implements KIP-63. Overview of main changes: - New byte-based cache that acts as a buffer for any persistent store and for forwarding changes downstream. - Forwarding record path

[5/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams

http://git-wip-us.apache.org/repos/asf/kafka/blob/86aa0eb0/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java -- diff --git

[4/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams

http://git-wip-us.apache.org/repos/asf/kafka/blob/86aa0eb0/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreSupplier.java -- diff --git

[2/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams

http://git-wip-us.apache.org/repos/asf/kafka/blob/86aa0eb0/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingKeyValueStoreTest.java -- diff --git