Skip to content

Integrated kafka#224

Open
MilanTyagi2004 wants to merge 2 commits into
Mamun-Al-Babu-Shikder:masterfrom
MilanTyagi2004:kafka-integration
Open

Integrated kafka#224
MilanTyagi2004 wants to merge 2 commits into
Mamun-Al-Babu-Shikder:masterfrom
MilanTyagi2004:kafka-integration

Conversation

@MilanTyagi2004
Copy link
Copy Markdown
Contributor

@MilanTyagi2004 MilanTyagi2004 commented Dec 14, 2025

Related Issue

Summary

  • Adds optional, auto-configured Kafka support to Spring Tx Board.
  • Automatically publishes every completed TransactionLog to a Kafka topic when spring-kafka is on the classpath.
    Existing REST, UI, and in-memory logging remain unaffected.

Changes Made

  • Added TxBoardKafkaProperties for configurable topic and enable/disable flag.

  • Added TxBoardKafkaAutoConfiguration to auto-create Kafka publisher if Kafka is present.

  • Added KafkaTransactionLogPublisher to send TransactionLog events to Kafka in a fail-safe, non-blocking way.

  • Registered auto-configuration in META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports (and
    spring.factories for Boot 2 support).

  • Updated library folder structure: com.sdlc.pro.txboard.kafka.

Testing

  • mvn clean install passes
  • mvn test passes
  • Manual testing performed

Notes for Reviewers

  • Kafka publishing is optional and auto-enabled only if Kafka is on the classpath.

  • Failures in publishing are caught; the application remains unaffected.

  • Compatible with Spring Boot 2.x, 3.x, and 4.x.

Checklist

  • I have merged the latest changes from upstream dev.
  • I have added necessary documentation (if appropriate).
  • I have added tests (if applicable) that prove my fix is effective or that my feature works.
  • All tests pass locally.

@MilanTyagi2004
Copy link
Copy Markdown
Contributor Author

@Mamun-Al-Babu-Shikder could you please review the PR

@Mamun-Al-Babu-Shikder
Copy link
Copy Markdown
Owner

@Mamun-Al-Babu-Shikder could you please review the PR

We are targeting this in v1.8.0
Hopefully we will look into this after version 1.7.0 is released.

Thank you for your valuable time and effort.

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.

Kafka Integration for Streaming Transaction Logs

2 participants