kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java [227:234]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                  null,
                  ack,
                  kafkaTopic,
                  selectPartition(key, messageBytes, orderingKey),
                  Schema.OPTIONAL_STRING_SCHEMA,
                  key,
                  Schema.BYTES_SCHEMA,
                  messageBytes,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java [265:272]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        null,
        ack,
        kafkaTopic,
        selectPartition(key, messageBytes, orderingKey),
        Schema.OPTIONAL_STRING_SCHEMA,
        key,
        Schema.BYTES_SCHEMA,
        messageBytes,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -