ImmutableList.Builder<KafkaColumnHandle> handleBuilder = ImmutableList.builder();
ImmutableMap.Builder<KafkaColumnHandle, KafkaFieldDecoder<?>> keyFieldDecoderBuilder = ImmutableMap.builder();
ImmutableMap.Builder<KafkaColumnHandle, KafkaFieldDecoder<?>> messageFieldDecoderBuilder = ImmutableMap.builder();
KafkaRowDecoder keyDecoder = registry.getRowDecoder(kafkaSplit.getKeyDataFormat());
KafkaRowDecoder messageDecoder = registry.getRowDecoder(kafkaSplit.getMessageDataFormat());
for (ConnectorColumnHandle handle : columns) {
KafkaColumnHandle columnHandle = handleResolver.convertColumnHandle(handle);
handleBuilder.add(columnHandle);