Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-587

Create SystemConsumer and SystemProducer for ActiveMQ

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • None

    Description

      ActiveMQ is a popular messaging queue. It will be great for Samza to be able to read from and write to it. The basic idea is:
      1. it will be separated into its own package
      2. it implements SystemAdmin, SystemConsumer, SystemProducer. ( check the org.apache.samza.system package in javadoc )
      3. it is written in Java. Thought previous implementation is using Scala (Kafka Implementation and FileSystem Implementation), we are moving from Scala to Java. All scala APIs are Java APIs.
      4. two systems mentioned in (3) could be used as a reference.

      Also see comment.

      Attachments

        Issue Links

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            Unassigned Unassigned
            closeuris Yan Fang

            Dates

              Created:
              Updated:

              Slack

                Issue deployment