Skip to content

Commit

Permalink
Fix schema-understand doc. (apache#11615)
Browse files Browse the repository at this point in the history 
* Fix schema-understand doc.

* Add some version change

Co-authored-by: congbo <congbobo184@github.com>
  • Loading branch information
@congbobo184 @ciaocloud
2 people authored and ciaocloud committed Oct 16, 2021
1 parent b9430a4 commit 3bcdf5c
Show file tree
Hide file tree
Showing 3 changed files with 45 additions and 27 deletions.
24 changes: 15 additions & 9 deletions site2/docs/schema-understand.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -327,7 +327,10 @@ Pulsar gets the schema definition from the predefined `struct` using an Avro lib
1. Create the _User_ class to define the messages sent to Pulsar topics.

```java
public class User {
@Builder
@AllArgsConstructor
@NoArgsConstructor
public static class User {
String name;
int age;
}
Expand All @@ -337,7 +340,7 @@ Pulsar gets the schema definition from the predefined `struct` using an Avro lib

```java
Producer<User> producer = client.newProducer(Schema.AVRO(User.class)).create();
producer.newMessage().value(User.builder().userName("pulsar-user").userId(1L).build()).send();
producer.newMessage().value(User.builder().name("pulsar-user").age(1).build()).send();
```

3. Create a consumer with a `struct` schema and receive messages
Expand Down Expand Up @@ -382,7 +385,10 @@ You can define the `schemaDefinition` to generate a `struct` schema.
1. Create the _User_ class to define the messages sent to Pulsar topics.

```java
public class User {
@Builder
@AllArgsConstructor
@NoArgsConstructor
public static class User {
String name;
int age;
}
Expand All @@ -391,17 +397,17 @@ You can define the `schemaDefinition` to generate a `struct` schema.
2. Create a producer with a `SchemaDefinition` and send messages.

```java
SchemaDefinition<User> schemaDefinition = SchemaDefinition.builder().withPojo(User.class).build();
Producer<User> producer = client.newProducer(schemaDefinition).create();
producer.newMessage().value(User.builder().userName("pulsar-user").userId(1L).build()).send();
SchemaDefinition<User> schemaDefinition = SchemaDefinition.<User>builder().withPojo(User.class).build();
Producer<User> producer = client.newProducer(Schema.AVRO(schemaDefinition)).create();
producer.newMessage().value(User.builder().name("pulsar-user").age(1).build()).send();
```

3. Create a consumer with a `SchemaDefinition` schema and receive messages

```java
SchemaDefinition<User> schemaDefinition = SchemaDefinition.builder().withPojo(User.class).build();
Consumer<User> consumer = client.newConsumer(schemaDefinition).subscribe();
User user = consumer.receive();
SchemaDefinition<User> schemaDefinition = SchemaDefinition.<User>builder().withPojo(User.class).build();
Consumer<User> consumer = client.newConsumer(Schema.AVRO(schemaDefinition)).subscribe();
User user = consumer.receive().getValue();
```

<!--END_DOCUSAURUS_CODE_TABS-->
Expand Down
24 changes: 15 additions & 9 deletions site2/website/versioned_docs/version-2.8.0/schema-understand.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -328,7 +328,10 @@ Pulsar gets the schema definition from the predefined `struct` using an Avro lib
1. Create the _User_ class to define the messages sent to Pulsar topics.

```java
public class User {
@Builder
@AllArgsConstructor
@NoArgsConstructor
public static class User {
String name;
int age;
}
Expand All @@ -338,7 +341,7 @@ Pulsar gets the schema definition from the predefined `struct` using an Avro lib

```java
Producer<User> producer = client.newProducer(Schema.AVRO(User.class)).create();
producer.newMessage().value(User.builder().userName("pulsar-user").userId(1L).build()).send();
producer.newMessage().value(User.builder().name("pulsar-user").age(1).build()).send();
```

3. Create a consumer with a `struct` schema and receive messages
Expand Down Expand Up @@ -383,7 +386,10 @@ You can define the `schemaDefinition` to generate a `struct` schema.
1. Create the _User_ class to define the messages sent to Pulsar topics.

```java
public class User {
@Builder
@AllArgsConstructor
@NoArgsConstructor
public static class User {
String name;
int age;
}
Expand All @@ -392,17 +398,17 @@ You can define the `schemaDefinition` to generate a `struct` schema.
2. Create a producer with a `SchemaDefinition` and send messages.

```java
SchemaDefinition<User> schemaDefinition = SchemaDefinition.builder().withPojo(User.class).build();
Producer<User> producer = client.newProducer(schemaDefinition).create();
producer.newMessage().value(User.builder().userName("pulsar-user").userId(1L).build()).send();
SchemaDefinition<User> schemaDefinition = SchemaDefinition.<User>builder().withPojo(User.class).build();
Producer<User> producer = client.newProducer(Schema.AVRO(schemaDefinition)).create();
producer.newMessage().value(User.builder().name("pulsar-user").age(1).build()).send();
```

3. Create a consumer with a `SchemaDefinition` schema and receive messages

```java
SchemaDefinition<User> schemaDefinition = SchemaDefinition.builder().withPojo(User.class).build();
Consumer<User> consumer = client.newConsumer(schemaDefinition).subscribe();
User user = consumer.receive();
SchemaDefinition<User> schemaDefinition = SchemaDefinition.<User>builder().withPojo(User.class).build();
Consumer<User> consumer = client.newConsumer(Schema.AVRO(schemaDefinition)).subscribe();
User user = consumer.receive().getValue();
```

<!--END_DOCUSAURUS_CODE_TABS-->
Expand Down
24 changes: 15 additions & 9 deletions site2/website/versioned_docs/version-2.8.1/schema-understand.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -328,7 +328,10 @@ Pulsar gets the schema definition from the predefined `struct` using an Avro lib
1. Create the _User_ class to define the messages sent to Pulsar topics.

```java
public class User {
@Builder
@AllArgsConstructor
@NoArgsConstructor
public static class User {
String name;
int age;
}
Expand All @@ -338,7 +341,7 @@ Pulsar gets the schema definition from the predefined `struct` using an Avro lib

```java
Producer<User> producer = client.newProducer(Schema.AVRO(User.class)).create();
producer.newMessage().value(User.builder().userName("pulsar-user").userId(1L).build()).send();
producer.newMessage().value(User.builder().name("pulsar-user").age(1).build()).send();
```

3. Create a consumer with a `struct` schema and receive messages
Expand Down Expand Up @@ -383,7 +386,10 @@ You can define the `schemaDefinition` to generate a `struct` schema.
1. Create the _User_ class to define the messages sent to Pulsar topics.

```java
public class User {
@Builder
@AllArgsConstructor
@NoArgsConstructor
public static class User {
String name;
int age;
}
Expand All @@ -392,17 +398,17 @@ You can define the `schemaDefinition` to generate a `struct` schema.
2. Create a producer with a `SchemaDefinition` and send messages.

```java
SchemaDefinition<User> schemaDefinition = SchemaDefinition.builder().withPojo(User.class).build();
Producer<User> producer = client.newProducer(schemaDefinition).create();
producer.newMessage().value(User.builder().userName("pulsar-user").userId(1L).build()).send();
SchemaDefinition<User> schemaDefinition = SchemaDefinition.<User>builder().withPojo(User.class).build();
Producer<User> producer = client.newProducer(Schema.AVRO(schemaDefinition)).create();
producer.newMessage().value(User.builder().name("pulsar-user").age(1).build()).send();
```

3. Create a consumer with a `SchemaDefinition` schema and receive messages

```java
SchemaDefinition<User> schemaDefinition = SchemaDefinition.builder().withPojo(User.class).build();
Consumer<User> consumer = client.newConsumer(schemaDefinition).subscribe();
User user = consumer.receive();
SchemaDefinition<User> schemaDefinition = SchemaDefinition.<User>builder().withPojo(User.class).build();
Consumer<User> consumer = client.newConsumer(Schema.AVRO(schemaDefinition)).subscribe();
User user = consumer.receive().getValue();
```

<!--END_DOCUSAURUS_CODE_TABS-->
Expand Down

0 comments on commit 3bcdf5c

Please sign in to comment.