Skip to content

[O2B-1474] Add kafka producer for beam mode change on stable beams - #12

Closed
graduta wants to merge 17 commits into
mainfrom
feature/O2B-1474/add-kafka-producer-for-beam-mode-change-on-SB
Closed

graduta wants to merge 17 commits into
mainfrom
feature/O2B-1474/add-kafka-producer-for-beam-mode-change-on-SB

Conversation

@graduta

@graduta graduta commented Oct 7, 2025 •

Copy link
Copy Markdown
Member

PR which:

  • adds Kafka Producer interface for reuse
  • adds beam mode change kafka producer to send events when "out of" & "into" stable beams
  • adds proto files that are to be used for publishing kafka events
  • adds protoc generated javac classes

@graduta graduta self-assigned this Oct 7, 2025
@graduta graduta added the enhancement New feature or request label Oct 7, 2025

Copilot AI left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

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

Pull Request Overview

Adds a Kafka producer to emit beam mode change events (for stable beams lifecycle) serialized with Protocol Buffers, integrates it into the DIP message processing flow, and introduces the corresponding .proto schemas and documentation updates.

  • Introduces common and event protobuf schemas (BeamInfo, BeamMode, Ev_BeamModeEvent).
  • Adds a generic Kafka producer wrapper and a BeamMode-specific producer, wiring it into DipMessagesProcessor and lifecycle management in AliDip2BK.
  • Updates README with purpose, requirements, and the new published event topic.

Reviewed Changes

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

Show a summary per file
File Description
src/alice/dip/protos/protos/common.proto Adds common protobuf types (User, WorkflowTemplateInfo, BeamInfo, BeamMode) used by events.
src/alice/dip/protos/events.proto Defines event messages including Ev_BeamModeEvent and references common types.
src/alice/dip/kafka/KafkaProducerInterface.java Provides a generic Kafka producer wrapper used by the BeamMode producer.
src/alice/dip/kafka/BeamModeEventsKafkaProducer.java Implements producer for beam mode events; serializes to protobuf and sends to Kafka.
src/alice/dip/DipMessagesProcessor.java Integrates the BeamMode producer and emits events on beam mode transitions.
src/alice/dip/AliDip2BK.java Creates, injects, and closes the BeamMode Kafka producer in the app lifecycle.
README.md Updates project description, requirements, and documents the new Kafka topic.

Tip: Customize your code reviews with copilot-instructions.md. Create the file or learn how to get started.

Comment thread src/alice/dip/kafka/BeamModeEventsKafkaProducer.java Outdated
Comment thread src/alice/dip/kafka/BeamModeEventsKafkaProducer.java
Comment thread src/alice/dip/protos/events.proto
Comment thread src/alice/dip/DipMessagesProcessor.java Outdated
Comment thread src/alice/dip/DipMessagesProcessor.java
Comment thread src/alice/dip/kafka/BeamModeEventsKafkaProducer.java Outdated
Comment thread src/alice/dip/protos/events.proto Outdated
Comment thread src/alice/dip/protos/events.proto Outdated
Comment thread README.md
Comment thread README.md
@graduta
graduta requested a review from Copilot October 7, 2025 17:18

Copilot AI left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

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

Pull Request Overview

Copilot reviewed 8 out of 10 changed files in this pull request and generated 3 comments.


Tip: Customize your code reviews with copilot-instructions.md. Create the file or learn how to get started.

Comment thread src/alice/dip/kafka/BeamModeEventsKafkaProducer.java
Comment thread src/alice/dip/kafka/KafkaProducerInterface.java
Comment thread README.md
Comment thread src/alice/dip/LhcInfoObj.java Outdated
@graduta
graduta requested a review from Copilot October 8, 2025 15:38

Copilot AI left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

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

Pull Request Overview

Copilot reviewed 9 out of 11 changed files in this pull request and generated 4 comments.


Tip: Customize your code reviews with copilot-instructions.md. Create the file or learn how to get started.

Comment thread src/alice/dip/kafka/BeamModeEventsKafkaProducer.java
Comment thread src/alice/dip/DipMessagesProcessor.java
Comment thread src/alice/dip/DipMessagesProcessor.java
Comment thread src/alice/dip/AliDip2BK.java
@graduta

graduta commented Oct 13, 2025

Copy link
Copy Markdown
Member Author

Closed in favour of: #15

@graduta graduta closed this Oct 13, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

enhancement New feature or request

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants