Kafka

KafkaSpout API

KafkaSpout API

 

KafkaSpout is a spout implementation that integrates with Storm and can read from Kafka clusters and then emit those messages as tuples within the Storm ecosystem. Here’s a sample code to create a simple KafkaSpout -

 

// ZooKeeper connection string

BrokerHosts hosts = new ZkHosts(zkConnString);

 

//Creating SpoutConfig Object

SpoutConfig spoutConfig = new SpoutConfig(hosts, 

   topicName, "/" + topicName UUID.randomUUID().toString());

 

//convert the ByteBuffer to String.

spoutConfig.scheme = new SchemeAsMultiScheme(new StringScheme());

 

//Assign SpoutConfig to KafkaSpout.

KafkaSpout kafkaSpout = new KafkaSpout(spoutConfig);

 

Top course recommendations for you

    PyTest Basics
    2 hrs
    Beginner
    2.8K+ Learners
    4.42  (144)
    Python MySQL
    1 hrs
    Beginner
    12.2K+ Learners
    4.46  (580)
    Python Automation Project
    2 hrs
    Beginner
    7K+ Learners
    4.58  (238)
    Python For Android
    2 hrs
    Beginner
    5.4K+ Learners
    4.52  (126)
    Kivy Projects
    2 hrs
    Beginner
    1.9K+ Learners
    4.5  (56)
    Regex in Python
    1 hrs
    Beginner
    2.7K+ Learners
    4.38  (154)
    Heap Sort Program in C
    1 hrs
    Beginner
    1.3K+ Learners
    4.44  (39)
    Merge Sort Algorithm Using Java
    1 hrs
    Beginner
    1.1K+ Learners
    4.65  (26)