Paul Grey 24925ed9b5
NIFI-11259 Added Redesigned Kafka Processors and Services
- Added ConsumeKafka and PublishKafka Processors with Kafka3ConnectionService
- Added Kafka 3 integration tests

This closes #8463

Co-authored-by: David Handermann <exceptionfactory@apache.org>
Signed-off-by: David Handermann <exceptionfactory@apache.org>
2024-06-24 17:55:06 -05:00

1.1 KiB

ConsumeKafkaIT

  • When additional test cases were added to ConsumeKafkaIT, intermittent test failures were observed. Experimenting with processor parameters yielded a learning that, in the test containers test environment, reuse of consumer group ID was confusing Kafka client. Use of fresh group ID for each test case led to repeatable successful test runs.