Browse Source

Merge branch 'master' of http://10.1.235.20:3000/rest/rest-guide

weihf 3 years ago
parent
commit
b3529a6947

+ 1 - 0
comp-example/src/test/java/com/ai/ipu/example/kafka/KafkaCustomerExample.java

6
import org.apache.kafka.clients.consumer.ConsumerRecord;
6
import org.apache.kafka.clients.consumer.ConsumerRecord;
7
import org.apache.kafka.clients.consumer.ConsumerRecords;
7
import org.apache.kafka.clients.consumer.ConsumerRecords;
8
import org.apache.kafka.clients.consumer.KafkaConsumer;
8
import org.apache.kafka.clients.consumer.KafkaConsumer;
9
9
import java.util.Arrays;
10
import java.util.Arrays;
10
import java.util.Properties;
11
import java.util.Properties;
11
12

+ 0 - 2
comp-example/src/test/java/com/ai/ipu/example/kafka/KafkaProducerExample.java

5
import org.apache.kafka.clients.producer.KafkaProducer;
5
import org.apache.kafka.clients.producer.KafkaProducer;
6
import org.apache.kafka.clients.producer.ProducerRecord;
6
import org.apache.kafka.clients.producer.ProducerRecord;
7
7
8
import java.util.ArrayList;
9
import java.util.List;
10
import java.util.Properties;
8
import java.util.Properties;
11
import java.util.Scanner;
9
import java.util.Scanner;
12
10

+ 0 - 2
comp-example/src/test/java/com/ai/ipu/example/rocketmq/RocketMQProducerExample.java

21
        producer.setVipChannelEnabled(false);
21
        producer.setVipChannelEnabled(false);
22
        producer.setNamesrvAddr("47.105.160.21:9876");
22
        producer.setNamesrvAddr("47.105.160.21:9876");
23
        producer.start();
23
        producer.start();
24
25
26
        try {
24
        try {
27
            Scanner sc = new Scanner(System.in);
25
            Scanner sc = new Scanner(System.in);
28
            int i = 0;
26
            int i = 0;