Apache Pig-Home
Apache Pig is an abstraction over MapReduce. It is a tool/platform which is used to analyze larger sets of data representing them as data flows. Pig is generally used with Hadoop;…
Apache Pig is an abstraction over MapReduce. It is a tool/platform which is used to analyze larger sets of data representing them as data flows. Pig is generally used with Hadoop;…
Kafka Tool packaged under “org.apache.kafka.tools.*. Tools are categorized into system tools and replication tools. Here we will discuss about apache kafka tools & application. System Tools System tools can be…
Here we will discuss about kafka real time application(twitter). Let us analyze a real time application to get the latest twitter feeds and its hashtags. Earlier, we have seen integration…
In this chapter, we will be discussing about how to integrate Apache Kafka with Spark Streaming API. Here we will discuss about integration with spark of apache kafka. About Spark…
In this chapter, we will learn how to integrate Kafka with Apache Storm. Here we will discuss about Integration with storm of apache kafka. About Storm Storm was originally created…
Consumer group is a multi-threaded or multi-machine consumption from Kafka topics. Here we will discuss about Consumer Group Example of apache kafka. Consumer Group Consumers can join a group by…
Here we will discuss about Simple Producer Example of apache kafka. Let us create an application for publishing and consuming messages using a Java client. Kafka producer client consists of…
First let us start implementing single node-single broker configuration and we will then migrate our setup to single node-multiple brokers configuration. Here we will discuss about basic operations of apache kafka. Hopefully…
Following are the steps for installing Java on your machine. Here we will discuss about installation steps of apache kafka. Step 1 - Verifying Java Installation Hopefully you have already…
As of now, we discussed the core concepts of Kafka. Let us now throw some light on the workflow of Kafka. Here we will discuss about workflow of apache kafka.…