code: def _make_topics_result(f, futmap):
          
          try:
              result = f.result()
              for topic, error in result.items():
                  fut = futmap.get(topic, None)
                  if fut is None:
                      raise RuntimeError("Topic {} not found in future-map: {}".format(topic, futmap))
  
                  if error is not None:
                      # Topic-level exception
                      fut.set_exception(KafkaException(error))
                  else:
                      # Topic-level success
                      fut.set_result(None)
          except Exception as e:
              # Request-level exception, raise the same for all topics
              for topic, fut in futmap.items():
                  fut.set_exception(e)
docs: Map per-topic results to per-topic futures in futmap.
          The result value of each (successful) future is None.