Skip to content

docs(kafka): kafka docs #120

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

Merged
merged 1 commit into from
Aug 30, 2024
Merged

docs(kafka): kafka docs #120

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions docs/docs/reactive-commons/1-getting-started.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -190,7 +190,7 @@ To enter the Kafka UI, open your browser and go to `http://localhost:8081`
## Spring Boot Application

The Spring Boot sample publishes and consumes messages with the `DomainEventBus`. This application illustrates how to
configure Reactive Commons using RabbitMQ in a Spring Boot environment.
configure Reactive Commons using Kafka in a Spring Boot environment.

To build your own application using the Reactive Commons API, you need to include a dependency to Reactive Commons.

Expand All @@ -210,7 +210,7 @@ dependencies {

Also you need to include the name for your app in the `application.properties`, it is important because this value will
be used
to name the application queues inside RabbitMQ:
to name the application group-id inside Kafka:

```properties
spring.application.name=MyAppName
Expand All @@ -224,7 +224,7 @@ spring:
name: MyAppName
```

You can set the RabbitMQ connection properties through spring boot with
You can set the Kafka connection properties through spring boot with
the [`spring.kafka.*` properties](https://docs.spring.io/spring-boot/docs/current/reference/html/application-properties.html)

```yaml
Expand All @@ -235,7 +235,7 @@ spring:

You can also set it in runtime for example from a secret, so you can create the `KafkaProperties` bean like:

```java title="org.reactivecommons.async.rabbit.config.RabbitProperties"
```java title="org.reactivecommons.async.kafka.config.KafkaProperties"

@Configuration
public class MyKafkaConfig {
Expand Down
8 changes: 4 additions & 4 deletions docs/docs/reactive-commons/9-configuration-properties.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -148,9 +148,9 @@ You can override this settings programmatically through a `AsyncKafkaPropsDomain
```java
package sample;

import org.reactivecommons.async.rabbit.config.RabbitProperties;
import org.reactivecommons.async.rabbit.config.props.AsyncProps;
import org.reactivecommons.async.rabbit.config.props.AsyncRabbitPropsDomainProperties;
import org.reactivecommons.async.kafka.config.KafkaProperties;
import org.reactivecommons.async.kafka.config.props.AsyncProps;
import org.reactivecommons.async.kafka.config.props.AsyncKafkaPropsDomainProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Primary;

Expand All @@ -163,7 +163,7 @@ public class MyDomainConfig {
KafkaProperties propertiesApp = new KafkaProperties();
propertiesApp.setBootstrapServers(List.of("localhost:9092"));

RabbitProperties propertiesAccounts = new RabbitProperties();
KafkaProperties propertiesAccounts = new KafkaProperties();
propertiesAccounts.setBootstrapServers(List.of("localhost:9093"));

return AsyncKafkaPropsDomainProperties.builder()
Expand Down
Loading