100644 blob 5914b789a14962dce4e285c11d95b884c37e6c7e	KafkaQueryChangeLogSourceIT.java
100644 blob 83f040d302e5cfd354574f507ca084e9687aba06	LocalQueryExecutorIT.java
100644 blob efbcf4bbaa5eda3946dd98712b77084163e9fa3c	LocalQueryExecutorTest.java