우리는 Servicetest와 Kafka가 내장 된 이상한 행동을 관찰하고 있습니다. @ClassRule
@Shared
KafkaEmbedded embeddedKafka = new KafkaEmbedded(1)
@Autowired
KafkaListenerEndpointRegistry endpointRegistry
def setupSpec() {
Kafka 주제에 메시지를 쓸 때 Spring Boot 응용 프로그램 내에서 spring-kafka KafkaTemplate을 사용하려고합니다. 나는 카프카에 쓰고 수업 시간에 @Configuration
@EnableKafka
public class KafkaConfig {
@Value("${kafka.broker.address}")
저는 spring-kafka 및 spring-kafka-test 버전 1.0.2.RELEASE를 사용하고 있습니다. 내 테스트 중 하나에서 내 응용 프로그램은 KafkaTemplate 및 대부분 기본 구성 설정을 사용하여 EmbeddedKafka 인스턴스의 단일 TopicPartion에 연속으로 100 개의 레코드를 보냅니다. 나는 Kafka 인스턴스에서
kafka에서 메시지를 받으면 장시간 실행되는 프로세스 (최대 20 초 소요)를 실행해야하므로 메시지를 성공한 것으로 간주해야합니다. 이 프로세스가 완료됩니다. 또한 각 메시지를 적어도 한 번 처리해야합니다. 다음 속성으로 KafkaMessageListenerContainer를 사용 생각 : MANUL_IMMEDIATE로 인정 모드 설정 형 Acknowle