@Test void testConfiguringInvalidCacheSize() { assertThrows( AxonConfigurationException.class, () -> builder().configuration(minimal(kafkaBroker)).producerCacheSize(-1).build() ); }
public static <K, V> Builder<K, V> builder() { return new Builder<>(); }
DefaultProducerFactory implements ProducerFactory<K, V> { public static <K, V> Builder<K, V> builder() { return new Builder<>(); } }
DefaultProducerFactory implements ProducerFactory<K, V> { public static <K, V> Builder<K, V> builder() { return new Builder<>(); } @SuppressWarnings("WeakerAccess") protected  DefaultProducerFactory(Builder<K, V> builder); }
DefaultProducerFactory implements ProducerFactory<K, V> { public static <K, V> Builder<K, V> builder() { return new Builder<>(); } @SuppressWarnings("WeakerAccess") protected  DefaultProducerFactory(Builder<K, V> builder); static Builder<K, V> builder(); @Override Producer<K, V> createProducer(); @Override ConfirmationMode confirmationMode(); Map<String, Object> configurationProperties(); String transactionIdPrefix(); @Override void shutDown(); }
DefaultProducerFactory implements ProducerFactory<K, V> { public static <K, V> Builder<K, V> builder() { return new Builder<>(); } @SuppressWarnings("WeakerAccess") protected  DefaultProducerFactory(Builder<K, V> builder); static Builder<K, V> builder(); @Override Producer<K, V> createProducer(); @Override ConfirmationMode confirmationMode(); Map<String, Object> configurationProperties(); String transactionIdPrefix(); @Override void shutDown();  }