Можно ли повторно использовать GlobalKTable?

Я хочу ReKey GlobalKTable (возможно, при его инициализации, поскольку я считаю, что они читаются только после создания).

Это возможно?

У меня есть две темы, с которыми я работаю в приложении Spring/Java Kafka Streams. Первый не уплотнен, второй есть. Оба используют Avro для своих ключей и значений.

Приложение передает записи из первой (несжатой) темы и прикрепляет дополнительные данные из сжатой темы через KStream#leftJoin. Сжатая тема была перенесена в приложение как GlobalKTable, создана с помощью StreamsBuilder#globalTable() и должна оставаться такой (мне нужна каждая запись из всех разделов темы, доступных в каждом экземпляре приложения).

Я знаю, что говорят о поддержке соединений без первичного ключа (https://issues.apache.org/jira/browse/KAFKA-3705), но, насколько мне известно, я пока не могу этого сделать...

@Configuration
@EnableKafkaStreams
public class StreamsConfig {

  @Autowired
  private MyCustomSerdes serdes;

  @Bean
  public KStream<AvroKeyOne, AvroValueOne> reKeyJoin(StreamsBuilder streamsBuilder) {

    GlobalKTable<AvroKeyOne, AvroValueOne> globalTable = streamsBuilder.globalTable("topicOne", Consumed.with(
      serdes.getAvroKeyOne()
      serdes.getAvroValueOne()
    ));

    KStream<AvroKeyTwo, AvroValueOne> kStream = streamsBuilder.stream("topicTwo", Consumed.with(
      serdes.getAvroKeyTwo(),
      serdes.getAvroValueOne()
    ));

    kStream.join(
      globalTable,
       /**
        * the KeyValueMapper. I need to rekey the Global table as well to the
        * corresponding String (which it's data will have) if I want this join
        * to return results
        */
      (streamKey, streamValue) -> {return streamKey.getNewStringKey()},
      (/**ValueJoiner Deal**/)
    );
  }

}