StreamsBuilder#table("my-topic",
  Consumed.with(AutoOffsetReset.EARLIEST));