File tree Expand file tree Collapse file tree 6 files changed +37
-15
lines changed Expand file tree Collapse file tree 6 files changed +37
-15
lines changed Original file line number Diff line number Diff line change @@ -27,15 +27,15 @@ in Pulsar documentation to start a Pulsar standalone locally.
27
27
git clone https://github.com/streamnative/pulsar-examples.git
28
28
```
29
29
``` bash
30
- cd pulsar-examples
30
+ cd pulsar-examples/clients
31
31
```
32
32
``` bash
33
33
mvn -am -pl schema clean package
34
34
```
35
35
36
36
3 . Run the avro schema producer example to produce 10 avro messages to a pulsar topic ` avro-payments ` .
37
37
``` bash
38
- mvn -pl schema exec:java -Dexec.mainClass= " io.streamnative.examples.schema.avro.AvroSchemaProducerExample"
38
+ java -cp schema/target/pulsar-schema-examples.jar io.streamnative.examples.schema.avro.AvroSchemaProducerExample
39
39
```
40
40
After running this producer example, you will see the following successful message.
41
41
``` bash
@@ -44,7 +44,7 @@ in Pulsar documentation to start a Pulsar standalone locally.
44
44
45
45
4 . Run the auto consumer example to receive the produced avro messages as generic records from topic ` avro-payments ` .
46
46
``` bash
47
- mvn -pl schema exec:java -Dexec.mainClass= " io.streamnative.examples.schema.generic.AutoConsumeSchemaConsumerExample"
47
+ java -cp schema/target/pulsar-schema-examples.jar io.streamnative.examples.schema.generic.AutoConsumeSchemaConsumerExample
48
48
```
49
49
After running this consumer example, you will see the following output.
50
50
``` bash
Original file line number Diff line number Diff line change @@ -27,15 +27,15 @@ in Pulsar documentation to start a Pulsar standalone locally.
27
27
git clone https://github.com/streamnative/pulsar-examples.git
28
28
```
29
29
``` bash
30
- cd pulsar-examples
30
+ cd pulsar-examples/clients
31
31
```
32
32
``` bash
33
33
mvn -am -pl schema clean package
34
34
```
35
35
36
36
3 . Run the Avro producer example to produce 10 avro messages to a pulsar topic ` avro-payments ` .
37
37
``` bash
38
- mvn -pl schema exec:java -Dexec.mainClass= " io.streamnative.examples.schema.avro.AvroSchemaProducerExample"
38
+ java -cp schema/target/pulsar-schema-examples.jar io.streamnative.examples.schema.avro.AvroSchemaProducerExample
39
39
```
40
40
After running this producer example, you will see the following successful message.
41
41
``` bash
@@ -44,7 +44,7 @@ in Pulsar documentation to start a Pulsar standalone locally.
44
44
45
45
4 . Run the Avro consumer example to receive the produced avro messages from topic ` avro-payments ` .
46
46
``` bash
47
- mvn -pl schema exec:java -Dexec.mainClass= " io.streamnative.examples.schema.avro.AvroSchemaConsumerExample"
47
+ java -cp schema/target/pulsar-schema-examples.jar io.streamnative.examples.schema.avro.AvroSchemaConsumerExample
48
48
```
49
49
After running this consumer example, you will see the following output.
50
50
``` bash
Original file line number Diff line number Diff line change @@ -30,20 +30,20 @@ in Pulsar documentation to start a Pulsar standalone locally.
30
30
git clone https://github.com/streamnative/pulsar-examples.git
31
31
```
32
32
``` bash
33
- cd pulsar-examples
33
+ cd pulsar-examples/clients
34
34
```
35
35
``` bash
36
36
mvn -am -pl schema clean package
37
37
```
38
38
39
39
3 . Run the consumer example to wait for receiving the produced key/value messages from topic ` keyvalue-inline-topic ` .
40
40
``` bash
41
- mvn -pl schema exec:java -Dexec.mainClass= " io.streamnative.examples.schema.kv.KeyValueInlineSchemaConsumerExample"
41
+ java -cp schema/target/pulsar-schema-examples.jar io.streamnative.examples.schema.kv.KeyValueInlineSchemaConsumerExample
42
42
```
43
43
44
44
4 . Open another terminal, run the producer example to produce 10 key/value messages to a pulsar topic ` keyvalue-inline-topic ` .
45
45
``` bash
46
- mvn -pl schema exec:java -Dexec.mainClass= " io.streamnative.examples.schema.kv.KeyValueInlineSchemaProducerExample"
46
+ java -cp schema/target/pulsar-schema-examples.jar io.streamnative.examples.schema.kv.KeyValueInlineSchemaProducerExample
47
47
```
48
48
After running this producer example, you will see the following successful message.
49
49
``` bash
Original file line number Diff line number Diff line change @@ -29,20 +29,20 @@ in Pulsar documentation to start a Pulsar standalone locally.
29
29
git clone https://github.com/streamnative/pulsar-examples.git
30
30
```
31
31
``` bash
32
- cd pulsar-examples
32
+ cd pulsar-examples/clients
33
33
```
34
34
``` bash
35
35
mvn -am -pl schema clean package
36
36
```
37
37
38
38
3 . Run the consumer example to wait for receiving the produced key/value messages from topic ` keyvalue-separated-topic ` .
39
39
``` bash
40
- mvn -pl schema exec:java -Dexec.mainClass= " io.streamnative.examples.schema.kv.KeyValueSeparatedSchemaConsumerExample"
40
+ java -cp schema/target/pulsar-schema-examples.jar io.streamnative.examples.schema.kv.KeyValueSeparatedSchemaConsumerExample
41
41
```
42
42
43
43
4 . Open another terminal, run the producer example to produce 10 key/value messages to a pulsar topic ` keyvalue-separated-topic ` .
44
44
``` bash
45
- mvn -pl schema exec:java -Dexec.mainClass= " io.streamnative.examples.schema.kv.KeyValueSeparatedSchemaProducerExample"
45
+ java -cp schema/target/pulsar-schema-examples.jar io.streamnative.examples.schema.kv.KeyValueSeparatedSchemaProducerExample
46
46
```
47
47
After running this producer example, you will see the following successful message.
48
48
``` bash
Original file line number Diff line number Diff line change @@ -27,15 +27,15 @@ in Pulsar documentation to start a Pulsar standalone locally.
27
27
git clone https://github.com/streamnative/pulsar-examples.git
28
28
```
29
29
``` bash
30
- cd pulsar-examples
30
+ cd pulsar-examples/clients
31
31
```
32
32
``` bash
33
33
mvn -am -pl schema clean package
34
34
```
35
35
36
36
3 . Run the Generic schema producer example to produce 10 generic records to a pulsar topic ` avro-payments ` .
37
37
``` bash
38
- mvn -pl schema exec:java -Dexec.mainClass= " io.streamnative.examples.schema.generic.GenericSchemaProducerExample"
38
+ java -cp schema/target/pulsar-schema-examples.jar io.streamnative.examples.schema.generic.GenericSchemaProducerExample
39
39
```
40
40
After running this producer example, you will see the following successful message.
41
41
``` bash
@@ -44,7 +44,7 @@ in Pulsar documentation to start a Pulsar standalone locally.
44
44
45
45
4 . Run the Avro consumer example to receive the produced generic records from topic ` avro-payments ` .
46
46
``` bash
47
- mvn -pl schema exec:java -Dexec.mainClass= " io.streamnative.examples.schema.avro.AvroSchemaConsumerExample"
47
+ java -cp schema/target/pulsar-schema-examples.jar io.streamnative.examples.schema.avro.AvroSchemaConsumerExample
48
48
```
49
49
After running this consumer example, you will see the following output.
50
50
``` bash
Original file line number Diff line number Diff line change 106
106
</execution >
107
107
</executions >
108
108
</plugin >
109
+ <plugin >
110
+ <groupId >org.apache.maven.plugins</groupId >
111
+ <artifactId >maven-assembly-plugin</artifactId >
112
+ <configuration >
113
+ <!-- get all project dependencies -->
114
+ <descriptorRefs >
115
+ <descriptorRef >jar-with-dependencies</descriptorRef >
116
+ </descriptorRefs >
117
+ <finalName >pulsar-schema-examples</finalName >
118
+ <appendAssemblyId >false</appendAssemblyId >
119
+ </configuration >
120
+ <executions >
121
+ <execution >
122
+ <id >make-assembly</id >
123
+ <!-- bind to the packaging phase -->
124
+ <phase >package</phase >
125
+ <goals >
126
+ <goal >single</goal >
127
+ </goals >
128
+ </execution >
129
+ </executions >
130
+ </plugin >
109
131
</plugins >
110
132
</build >
111
133
</project >
You can’t perform that action at this time.
0 commit comments