INNER CODE UNIT · Java

getConfigs

andreschaffer/microservices-testing-examples · special-membership-service/src/main/java/specialmembershipservice/bootstrap/EventPublisherConfiguration.java:33

  public Map<String, Object> getConfigs() {
    Map<String, Object> configs = new HashMap<>();
    configs.put(ACKS_CONFIG, "all");
    configs.put(RETRIES_CONFIG, 1);
    configs.put(BATCH_SIZE_CONFIG, 16384);
    configs.put(LINGER_MS_CONFIG, 1);
    configs.put(BUFFER_MEMORY_CONFIG, 33554432);
    configs.put(KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
    configs.put(VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
    configs.putAll(this.configs);
    return configs;
  }

  public void setConfigs(Map<String, Object> configs) {
    this.configs = configs;
  }
}

View source record →