private Properties getCoordinatorStreamProperties(KafkaConfig config) {
    Properties coordinatorStreamProperties = new Properties();
    coordinatorStreamProperties.put(TopicConfig.CLEANUP_POLICY_CONFIG, TopicConfig.CLEANUP_POLICY_COMPACT);
    coordinatorStreamProperties.put(TopicConfig.SEGMENT_BYTES_CONFIG, config.getCoordinatorSegmentBytes());

    return coordinatorStreamProperties;
  }
Fetch stream properties for all intermediate streams.

@param config kafka system config
@return a {@link Map} from {@code streamId} to stream {@link Properties}
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java