Package tweetoscope.tweetsAggregator

Class TwitterKafkaAggregator

java.lang.Object

tweetoscope.tweetsAggregator.TwitterKafkaAggregator

public class TwitterKafkaAggregator
extends Object

Classe pour agréger les hashtags provenant d'un topic Kafka et afficher les meilleurs hashtags.

Constructor Summary

Constructors

Constructor	Description
TwitterKafkaAggregator(String bootstrapServers, String tweetTopicName, String destinationTopicName, int nbLeaders)	Constructeur de la classe.

Method Summary

Modifier and Type	Method	Description
void	aggregate()	Méthode principale d'agrégation qui lit les messages de Kafka et met à jour les hashtags populaires.
static void	main(String[] args)	Méthode principale pour exécuter l'agrégation.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TwitterKafkaAggregator

public TwitterKafkaAggregator(String bootstrapServers,
 String tweetTopicName,
 String destinationTopicName,
 int nbLeaders)

Constructeur de la classe.

Parameters:

bootstrapServers - Les serveurs Bootstrap Kafka.

tweetTopicName - Le nom du topic Kafka pour les tweets.

destinationTopicName - Le nom du topic Kafka de destination.

nbLeaders - Le nombre de leaders à afficher.

Method Details

aggregate

public void aggregate()

Méthode principale d'agrégation qui lit les messages de Kafka et met à jour les hashtags populaires.

main

public static void main(String[] args)

Méthode principale pour exécuter l'agrégation.

Parameters:

args - Arguments de la ligne de commande.