Έχουμε ένα σχήμα αλληλεπίδρασης συστατικών: Ας υποθέσουμε ότι είναι υπηρεσίες που προορίζονται για τη δημιουργία και διαχείριση εκδηλώσεων για διευθυντές ανθρώπινων πόρων. Αποστέλλουμε ένα μήνυμα στην Υπηρεσία 1, (που αναπτύσσεται σε Kubernetes) για την απόκτηση ή επεξεργασία δεδομένων μέσω REST API. Η Υπηρεσία 1 επεξεργάζεται τα δεδομένα και στη συνέχεια τα στέλνει στο Kafka. Η Υπηρεσία 2 (επίσης αναπτυγμένη σε Kubernetes) διαβάζει τα μηνύματα από το Kafka και μετατρέπει όλες τις ληφθείσες πληροφορίες σε άλλο format, και στη συνέχεια τα αποθηκεύει στη βάση δεδομένων. Ως χρήστης, στείλαμε ένα αίτημα δημιουργίας εκδήλωσης μέσω REST στην Υπηρεσία 1, και στη συνέχεια ελέγξαμε την ύπαρξη αυτού του γεγονότος στη βάση δεδομένων με ένα ερώτημα Select. Αλλά δεν βρέθηκε αυτό το γεγονός στη βάση. Ξεκινήσαμε να ερευνούμε το πρόβλημα και διαπιστώσαμε ότι το μήνυμα είχε κολλήσει στο επίπεδο του Kafka: απλώς δεν διαβάστηκε από την Υπηρεσία 2. Πώς θα εντοπίσουμε γιατί το μήνυμα δεν διαβάστηκε;