Eliminated unnecessary connection pooling at the service layer so that a single Consumer is made available to the processor. This allows the processor to rollback offsets and provides a simpler API.
This closes#9298
Signed-off-by: David Handermann <exceptionfactory@apache.org>
Fixed error handling in several situations. Cleaned up leaky abstraction. Some code cleanup, fixed default values for time-based properties to use 'sec' instead of 's' to adhere to typical conventions.
Signed-off-by: David Handermann <exceptionfactory@apache.org>
- Upgraded Kafka Clients from 3.7.1 to 3.8.0
- Inheriting from the correct base services-api instead of shared-bundle then identifying missing explicit dependencies of Kafka processors commons-lang3 and commons-codec
Signed-off-by: David Handermann <exceptionfactory@apache.org>
- Removed references to nifi-property-utils under nifi-extension-bundles
This closes#9169
Signed-off-by: David Handermann <exceptionfactory@apache.org>
- 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>
Mark Payne
exceptionfactory
Joe Witt
Paul Grey