Uploaded image for project: 'AeroGear'
  1. AeroGear
  2. AEROGEAR-6663

First Kafka Consumer usage in UPS

XMLWordPrintable

    • Icon: Task Task
    • Resolution: Done
    • Icon: Major Major
    • None
    • None
    • None

      With the client library integrated we could add a first, simple consumer, that polls some messages/records inside the UPS, from a defined topic

            [AEROGEAR-6663] First Kafka Consumer usage in UPS

            Polina Koleva (Inactive) added a comment -

            The task is ready github branch. I am waiting for your feedback to make a pull request. Is the implementation what did you expect?

            Polina Koleva (Inactive) added a comment - The task is ready github branch . I am waiting for your feedback to make a pull request. Is the implementation what did you expect?

            Matthias Wessendorf added a comment -

            Simple is good enough now.

            A problem is, that w/o the EE programming model, we manually have to connect the consumer. Out of the box we have no "auto receive". My Kafka CDI extension provides a simple model for that

            Matthias Wessendorf added a comment - Simple is good enough now. A problem is, that w/o the EE programming model, we manually have to connect the consumer. Out of the box we have no "auto receive". My Kafka CDI extension provides a simple model for that

            Polina Koleva (Inactive) added a comment -

            mwessend@redhat.com
            I suppose for now you meant just start a consumer, read the last message(or unread messages) and update the metrics and finally stop the consumer. Or you want to start a consumer only the first time the endpoint is invoked and has it running afterwards?

            Polina Koleva (Inactive) added a comment - mwessend@redhat.com I suppose for now you meant just start a consumer, read the last message(or unread messages) and update the metrics and finally stop the consumer. Or you want to start a consumer only the first time the endpoint is invoked and has it running afterwards?

            Matthias Wessendorf added a comment -

            A good first section for a simple consumer would be creating a consumer that reads the ACK data from the topic and executes the same code (e.g. calling the service), like in here:

            https://github.com/aerogear/aerogear-unifiedpush-server/blob/GSOC_2017_kafka/jaxrs/src/main/java/org/jboss/aerogear/unifiedpush/rest/registry/installations/InstallationRegistrationEndpoint.java#L230

            Matthias Wessendorf added a comment - A good first section for a simple consumer would be creating a consumer that reads the ACK data from the topic and executes the same code (e.g. calling the service), like in here: https://github.com/aerogear/aerogear-unifiedpush-server/blob/GSOC_2017_kafka/jaxrs/src/main/java/org/jboss/aerogear/unifiedpush/rest/registry/installations/InstallationRegistrationEndpoint.java#L230

              Unassigned Unassigned
              mwessend@redhat.com Matthias Wessendorf
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: