@Test void testBuildingWithInvalidGroupIdSuffixFactoryShouldThrowAxonConfigurationException() { assertThrows( AxonConfigurationException.class, () -> StreamableKafkaMessageSource.builder().groupIdSuffixFactory(null) ); }
public static <K, V> Builder<K, V> builder() { return new Builder<>(); }
StreamableKafkaMessageSource implements StreamableMessageSource<TrackedEventMessage<?>> { public static <K, V> Builder<K, V> builder() { return new Builder<>(); } }
StreamableKafkaMessageSource implements StreamableMessageSource<TrackedEventMessage<?>> { public static <K, V> Builder<K, V> builder() { return new Builder<>(); } protected  StreamableKafkaMessageSource(Builder<K, V> builder); }
StreamableKafkaMessageSource implements StreamableMessageSource<TrackedEventMessage<?>> { public static <K, V> Builder<K, V> builder() { return new Builder<>(); } protected  StreamableKafkaMessageSource(Builder<K, V> builder); static Builder<K, V> builder(); @Override BlockingStream<TrackedEventMessage<?>> openStream(TrackingToken trackingToken); }
StreamableKafkaMessageSource implements StreamableMessageSource<TrackedEventMessage<?>> { public static <K, V> Builder<K, V> builder() { return new Builder<>(); } protected  StreamableKafkaMessageSource(Builder<K, V> builder); static Builder<K, V> builder(); @Override BlockingStream<TrackedEventMessage<?>> openStream(TrackingToken trackingToken);  }