Comment faire pour automatiser le Test Kafka

Nous avons mis au point un petit système,à l'aide de kafka à la file d'attente les données et de les consommer plus tard que les données à placer des ordres pour les utilisateurs.
Nous avons testé certaines choses manuellement, mais maintenant, notre objectif est d'automatiser le processus.
Est-il un client disponible pour le tester.Pendant googler les choses, j'ai trouvé des moyens de test de l'Unité à l'aide de kafka client lui-même, mais mon but est de tester le système dans son ensemble.
Veuillez Vous Guide

EDIT: notre but est simplement de l'API de test c'est à dire, juste le back-end pas l'INTERFACE utilisateur

Dans mon expérience, jusqu'à présent, le test d'un kafka à base de système autonome de l'environnement (seul kafka courtier, seule gardienne d'animaux, une seule partition, peu de consommateurs/producteurs de l'exécution séquentielle/synchrone) fonctionne très bien. Vous pouvez exécuter la synchronisation et les problèmes de synchronisation avec les décalages et le tout dans un environnement réel où votre système produit & consomme en temps réel et vous êtes en train de puiser dans le bus pour valider les données à passer au travers. C'est le cas wehre vivre env a plusieurs courtiers, les gardiens de zoo, des partitions, des producteurs & les consommateurs, et éventuellement asynchrone flux.

OriginalL'auteur Alpana Chauhan | 2015-05-11

  1. 6

    Vous pouvez commencer à Kafka par programme dans votre test d'intégration, Kafka utilise Zookeeper donc firsly regarder Zookeeper TestingServer - instance de cette classe crée et démarre la Zk serveur en utilisant le port donné.

    Ensuite, regardez KafkaServerStartable.scala, vous devez fournir la configuration des points à votre mémoire Zk serveur et invoquer startup() méthode, voici un peu de code:

    import kafka.server.KafkaConfig; 
import kafka.server.KafkaServerStartable;
import java.util.Properties;

public KafkaTest() {
    Properties properties = createProperties();
    KafkaConfig kafkaConfig = new KafkaConfig(properties);
    KafkaServerStartable kafka = new KafkaServerStartable(kafkaConfig);
    kafka.startup();
}

    Espère que cela aide:)

    salut, merci, peut-être que je manque de compréhension sur le sujet, mais notre kafka est déployé sur un serveur distant, vais-je être en mesure d'y accéder par la façon dont vous l'avez suggéré, à partir de ma machine locale ..
    Je vous suggère de commencer Kafka avant votre suite de tests, dans ce cas, vous n'avez pas à se connecter à un serveur distant. Je pense que c'est la meilleure solution parce que votre tests ne sont pas dépend des ressources externes.

    OriginalL'auteur Paweł Szymczyk

  2. 0

    - Dessous de la réponse est pour quelqu'un qui cherche encore un exemple de travail.

    Créé échantillon en mémoire kafka pour l'intégration des tests à l'aide de KafkaServerStartable. Quelqu'un pourrait étendre cette fonctionnalité à leurs cas d'utilisation.

    • Aucune modification nécessaire. Facile à télécharger et à exécuter.
    • Ajout d'un exemple de cas de test pour couvrir de produire et de consommer message sur un sujet.

    Checkout le lien ici --> Kafka Test D'Intégration

    OriginalL'auteur Arunmozhi

  3. 0

    Vous pouvez aller de l'intégration-tests ou à la fin à la fin de l'essai, par l'éducation de Kafka dans un docker conteneur. Si vous utilisez Apache kafka-clients:2.1.0, alors vous n'avez pas besoin de traiter avec ZooKeeper au niveau de l'API, tandis que la production ou la consommation les enregistrements.

    Dockerizing Kafka, et test permet de couvrir les scénarios dans un seul nœud ainsi que multi-nœud Kafka cluster. De cette façon, vous n'avez pas à tester contre Maquette/En Mémoire de Kafka une fois, puis réel Kafka plus tard.

    Si vous avez trop de scénarios de test pour la couverture, vous pouvez aller pour Kafka declarative testing comme docker-compose style, par lequel vous pouvez éliminer le Kafka de l'API client de codage.

    OriginalL'auteur Sidd Gautama