Hub
NodeNode / Source

Kafka Consumer

KNIME Labs Kafka Streamable
Drag & drop
Like
Copy short link

This node allows to consume messages from a Kafka cluster for given topics and to store them in a table.
Note: Offsets are committed at the end of the nodes execution as well as whenever the partitions become reassigned.

Node details

Input ports
  1. Type: KafkaConnection
    Kafka connection
    Connection details used to create the Kafka Consumer
Output ports
  1. Type: Table
    Data table
    Data table storing all the consumed messages

Extension

The Kafka Consumer node is part of this extension:

Related workflows & nodes

  1. Kafka_write_and_read
    There has been no description set for this workflow's metadata.
    emilio_s > Public > Kafka_demo
  2. MDF meets Apache Kafka
    MDF Kafka Apache
    +8
    The MDF Reader node extracts sensor data about Motor and Turbine speed from a MDF file. T…
    knime > Examples > 01_Data_Access > 10_Other > 01_MDF_meets_Apache_Kafka
  3. Knime Integration with Kafka
    Kafka Kafka extension knime ETL
    +1
    This workflow represents a worfklow that receives information from kafka, perform operati…
    swantikag > Public > KafkaIntegration > Kafka_integration