Repository: kafka
Updated Branches:
refs/heads/trunk 616321bcb -> 68712dcde
KAFKA-6308; Connect Struct should use deepEquals/deepHashCode
This changes the Struct's equals and hashCode method to use Arrays#deepEquals
and Arrays#deepHashCode, respectively. This resolves a problem where two
str
Repository: kafka
Updated Branches:
refs/heads/trunk 1cf7ec87d -> 616321bcb
KAFKA-6102; Consolidate MockTime implementations between connect and clients
Author: Colin P. Mccabe
Reviewers: Randall Hauch , Jason Gustafson
Closes #4105 from cmccabe/KAFKA-6102
Project: http://git-wip-us.apa
Repository: kafka
Updated Branches:
refs/heads/trunk d1a9252ca -> 1cf7ec87d
KAFKA-6360: Clear RocksDB Segments when store is closed
Now that we support re-initializing state stores, we need to clear the segments
when the store is closed so that they can be re-opened.
Author: Damian Guy
Rev