kafka git commit: KAFKA-6308; Connect Struct should use deepEquals/deepHashCode

2017-12-14 Thread jgus
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

kafka git commit: KAFKA-6102; Consolidate MockTime implementations between connect and clients

2017-12-14 Thread jgus
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

kafka git commit: KAFKA-6360: Clear RocksDB Segments when store is closed

2017-12-14 Thread guozhang
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