All notable changes to this project will be documented in this file.
The format is based on Keep a Changelog and this project adheres to Semantic Versioning
- support for sending tombstone message from kafka producer plugin
- Upgrade template to V6.0.1
- upgrades to use cmem-plugin-base 4.3.0 (for CMEM 23.3)
- SASL Password parameter type from StringParameterType to PasswordParameterType
- upload of file resources was broken for 23.2
- upgrades to use cmem-plugin-base 4.1.0 (for CMEM 23.2, python 3.11)
Client_Id
parameter has been added to the advanced section of Kafka Consumer.- When the
Client_Id
field is empty, the plugin defaults toDNS:TASK ID
. Local Consumer Queue Size
parameter to limit local consumer queue size- Consume input entities in KafkaProducerPlugin to generate messages
- Generate output entities in KafkaConsumerPlugin from messages
- Consume JSON dataset in KafkaProducerPlugin to generate messages
- Generate JSON dataset in KafkaConsumerPlugin from messages
Compression Type
parameter has added to support standard compressionmessage limit
parameter has been added to the advanced section of kafka consumerdisable commit
parameter has been added to the advanced section of kafka consumer
Messages Dataset
Parameter moved from the advanced section to Main section (will change again in future)- Replace
none
witherror
in Auto Offset Reset parameter choice list - moved kakfa producer/consumer configuration check from init to validate() and calling explictly from execute()
- resolved endless loop caused by improper kafka server configuration
- generate entities with "message as plain value"
- Kafka Consumer (Receive Messages) Plugin
- Documentation and help texts
- upgrade to confluent-kafka 1.9.2
- use requests response stream for xml parsing (avoid out of memory)
- small docu issues
- initial version of a kafka producer plugin