Skip to content

APP-9587 : add simple message processor #119

Open
niteesh-atlan wants to merge 9 commits intomainfrom
add-message-processor
Open

APP-9587 : add simple message processor #119
niteesh-atlan wants to merge 9 commits intomainfrom
add-message-processor

Conversation

@niteesh-atlan
Copy link
Copy Markdown

@niteesh-atlan niteesh-atlan commented Dec 19, 2025

Changelog

APP-9587
Scope

  • Single / Bulk message processing
  • Sample Retry and message failures.
  • DLQ addition

SDK PR - atlanhq/application-sdk#898

Additional context (e.g. screenshots, logs, links)

  • to be added

Checklist

  • Additional tests added
  • All CI checks passed
  • Relevant documentation updated

@github-actions
Copy link
Copy Markdown

github-actions Bot commented Dec 19, 2025

📦 Trivy Vulnerability Scan Results

Schema Version Created At Artifact Type
2 2026-01-05T18:00:11.949171341Z . filesystem

Report Summary

Target Type Vulnerabilities . filesystem ✅ None found

Scan Result Details

✅ No vulnerabilities found during the scan for ..

@github-actions
Copy link
Copy Markdown

github-actions Bot commented Dec 19, 2025

📦 Trivy Secret Scan Results

Schema Version Created At Artifact Type
2 2026-01-05T18:00:23.593663242Z . filesystem

Report Summary

Target Type Secrets . filesystem ✅ None found

Scan Result Details

✅ No secrets found during the scan for ..

@niteesh-atlan niteesh-atlan marked this pull request as ready for review December 24, 2025 15:44
Copilot AI review requested due to automatic review settings December 24, 2025 15:44
@niteesh-atlan niteesh-atlan changed the title add simple message processor add simple message processor Dec 24, 2025
Copy link
Copy Markdown

Copilot AI left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Pull request overview

This PR introduces a quickstart example for a simple Kafka message processor using the Atlan Application SDK. The implementation demonstrates message processing via Dapr PubSub with callback handlers, supporting both single message and bulk message processing patterns without Temporal workflow orchestration.

Key Changes:

  • Added a message processor application with PubSub subscription handlers for processing Kafka events
  • Included a message publisher utility for testing and generating sample events
  • Provided configuration files, documentation, and a web-based monitoring UI

Reviewed changes

Copilot reviewed 7 out of 8 changed files in this pull request and generated 9 comments.

Show a summary per file
File Description
quickstart/simple-message-processor/pyproject.toml Project configuration with dependencies, build settings, and task definitions
quickstart/simple-message-processor/main.py Main application implementing message processing handlers for single and bulk subscriptions
quickstart/simple-message-processor/publish_messages.py Utility script for publishing test messages to Kafka via Dapr
quickstart/simple-message-processor/README.md Comprehensive documentation covering architecture, usage, and configuration
quickstart/simple-message-processor/.env.example Environment variable template for Kafka, Dapr, and application configuration
quickstart/simple-message-processor/frontend/templates/index.html Web UI template for monitoring message processing statistics
quickstart/simple-message-processor/frontend/static/index.html Static web UI file (appears to be duplicate of templates version)

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

Comment thread quickstart/simple-message-processor/.env.example Outdated
Comment thread quickstart/simple-message-processor/publish_messages.py
Comment thread quickstart/simple-message-processor/publish_messages.py Outdated
Comment thread quickstart/simple-message-processor/main.py Outdated
Comment thread quickstart/simple-message-processor/frontend/static/index.html Outdated
Comment thread quickstart/simple-message-processor/README.md Outdated
Comment thread quickstart/simple-message-processor/pyproject.toml Outdated
Comment thread quickstart/simple-message-processor/publish_messages.py
Comment thread quickstart/simple-message-processor/main.py Outdated
@niteesh-atlan niteesh-atlan changed the title add simple message processor APP-9587 : add simple message processor Dec 24, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants