Der Test verwendet die `@Bean` von `EndlessConsumer`

[demos/kafka/training] / src / main / java / de / juplo / kafka / StateRepository.java

package de.juplo.kafka;

import org.springframework.data.mongodb.repository.MongoRepository;

import java.util.Optional;


public interface StateRepository extends MongoRepository<StateDocument, String>
{
  public Optional<StateDocument> findById(String partition);
}