Integrate Kafka Without Custom Configuration Class #9

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Open

faizakram wants to merge 1 commit into main from feature/configure-Kafka

Owner

faizakram commented Jan 16, 2025

Summary

This Pull Request introduces support for Kafka integration, including:

Producer and Consumer configurations.
Application properties for Kafka setup.
Example implementations for publishing and subscribing to Kafka topics.

Changes Implemented

Added KafkaProducerService for producing messages.
Implemented KafkaConsumerService with annotated listeners.
Configured application properties for producer and consumer.
Unit tests for producer and consumer services.

How to Test

Run the Spring Boot application locally.
Ensure Kafka is running on localhost:9092.

Use the /kafka/publish endpoint to send messages:

curl -X POST "http://localhost:8080/kafka/publish?message=HelloKafka"


          Add Support for Kafka Integration

aa07e22

faizakram changed the title ~~Add Support for Kafka Integration~~ Integrate Kafka Without Custom Configuration Class

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet