@Test void testBuildWithInvalidGroupIdThrowsAxonConfigurationException() { assertThrows(AxonConfigurationException.class, () -> SubscribableKafkaMessageSource.builder().groupId(null)); }
public static <K, V> Builder<K, V> builder() { return new Builder<>(); }
SubscribableKafkaMessageSource implements SubscribableMessageSource<EventMessage<?>> { public static <K, V> Builder<K, V> builder() { return new Builder<>(); } }
SubscribableKafkaMessageSource implements SubscribableMessageSource<EventMessage<?>> { public static <K, V> Builder<K, V> builder() { return new Builder<>(); } @SuppressWarnings("WeakerAccess") protected  SubscribableKafkaMessageSource(Builder<K, V> builder); }
SubscribableKafkaMessageSource implements SubscribableMessageSource<EventMessage<?>> { public static <K, V> Builder<K, V> builder() { return new Builder<>(); } @SuppressWarnings("WeakerAccess") protected  SubscribableKafkaMessageSource(Builder<K, V> builder); static Builder<K, V> builder(); @Override Registration subscribe(java.util.function.Consumer<List<? extends EventMessage<?>>> eventProcessor); void start(); void close(); }
SubscribableKafkaMessageSource implements SubscribableMessageSource<EventMessage<?>> { public static <K, V> Builder<K, V> builder() { return new Builder<>(); } @SuppressWarnings("WeakerAccess") protected  SubscribableKafkaMessageSource(Builder<K, V> builder); static Builder<K, V> builder(); @Override Registration subscribe(java.util.function.Consumer<List<? extends EventMessage<?>>> eventProcessor); void start(); void close();  }