100644 blob 5914b789a14962dce4e285c11d95b884c37e6c7e	KafkaQueryChangeLogSourceIT.java
100644 blob f9c8a030e177a119f02b0ccbb8880ce01ec2d460	LocalQueryExecutorIT.java
100644 blob c0f888ea26b6317fe4ccd04c9d14eac582c8bdc8	LocalQueryExecutorTest.java