@Test void replayOverwrites() throws IOException {
    Span span = Span.newBuilder().traceId("10").id("10").name("receive")
      .kind(Span.Kind.CONSUMER)
      .localEndpoint(Endpoint.newBuilder().serviceName("app").build())
      .remoteEndpoint(Endpoint.newBuilder().serviceName("kafka").build())
      .timestamp(TODAY * 1000)
      .build();

    storage.accept(List.of(span)).execute();
    storage.accept(List.of(span)).execute();

    assertThat(storage.getDependencies(TODAY + 1000L, TODAY).execute()).containsOnly(
      DependencyLink.newBuilder().parent("kafka").child("app").callCount(1L).build()
    );
  }
It should be safe to run dependency link jobs twice
zipkin/src/test/java/zipkin2/storage/InMemoryStorageTest.java