2 products found for "kafka"

Apache Kafka is an open-source distributed event streaming platform used by thousands of companies for high-performance data pipelines, streaming analytics, data integration, and mission-critical applications. A Kafka Event Monitor is a Universal Extension responsible for monitoring events (messages) from topics in Kafka. Key Features: This Universal Extension provides the following main features: Monitor messages and consume a Kafka message by consumer group topic subscriptionAuthenticate against Kafka using PLAINTEXT, SASL_SSL or SSL security protocolCapability to filter Kafka messages based on the value of the message. Number, String and JSON filter patterns are supported.Capability to fetch dynamically Kafka topics, during task creation.Capability to control the partition assignment strategy, as well as session-related timeout values Typically this extension can be used to monitor events from Kafka and upon successful execution to trigger workflows or other tasks, or just to pass information related to the Kafka event within UAC. What's New in V1.1.0With this new release client authentication over SSL is supported.  

Apache Kafka is an open-source distributed event streaming platform used by thousands of companies for high-performance data pipelines, streaming analytics, data integration, and mission-critical applications. This integration is responsible for publishing events (messages) and topics in Kafka. Key Features: This Universal Extension supports the following main features: Perform authentication towards Kafka, using PLAINTEXT or SASL_SSL security protocol Send a message to Kafka with the capability to select the topic, the partition, the message key, the message value and message metadata Capability to control the transport of the messages by configuring the message acknowledgment strategy and the request timeout Capability to fetch dynamically topics and partitions from kafka for selection during task creation Capability to automatically select the serialization method depending on the key/value message data types What's New in V1.2.0This new release improves robustness of this integration and adds a number of useful features:Support for client authentication over SSL against Kafka bootstrap server.Extension Output is now provided upon successful execution.Debug mode execution is enhanced to properly close extension execution.Partition field enhanced to show and use all its dependent fields.