public static void processSync(StreamOperatorTask task, IncomingMessageEnvelope ime, MessageCollector collector,
      TaskCoordinator coordinator, TaskCallback callback) {
    final CountDownLatch latch = new CountDownLatch(1);
    doAnswer(invocation -> {
      latch.countDown();
      return null;
    }).when(callback).complete();
    task.processAsync(ime, collector, coordinator, callback);
    try {
      latch.await(1000, TimeUnit.MILLISECONDS);
    } catch (InterruptedException e) {
    }
  }
Adds the streams.stream-id.* configurations for the provided {@code streamId} to the provided {@code configs} Map.

@param configs the configs Map to add the stream configurations to
@param streamId the id of the stream
@param systemName the system for the stream
@param physicalName the physical name for the stream
samza-core/src/test/java/org/apache/samza/testUtils/StreamTestUtils.java