consumer

Consumer

This application consumes messages from 2 topcis - issued-token and new-user-created

The reader responsible for reading messages on the "issued-token" topic requires manual committing of messages and hence used the FetchMessage API coupled with the CommitMessages API from kafka-go. #

However in case of the "new-user-created" topic committing of messages is delegated to kafka-go itself using the ReadMessage API. #

The application comes with out of the box support for graphql subscriptions. For the purpose of demoing the flow of orchestrating subscritpions on consumption of messages the userNotification subscritpion is triggered when the a new token is issued or a new user is created.

• new-user-created
• issued-token

You can use the following subscription to receive notifications.

  subscription UserNotification {
    userNotification {
      id
      firstName
      lastName
    }
  }