INNER CODE UNIT · Java

setTopic

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

  public void setTopic(String topic) {
    this.topic = topic;
  }

  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) {

View source record →