INNER CODE UNIT · Java

getTopic

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

  public String getTopic() {
    return topic;
  }

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

View source record →