dependency

• kafka client 2.2.0
• spring boot
• goudai runner

  Usage

Update

• V1.0.1
  
  1.支持故障重启，默认启用故障重启，重启间隔为20s秒默认
  
  2.支持idea自动补全
• V1.0.2
  
  修改groupId 发布到中央仓库
• v2.2.1
  
  支持最新版kafka-clients(2.2.0)

consumer

• add dependency to maven

  <dependency>
     <groupId>io.github.goudai</groupId>
     <artifactId>spring-boot-starter-kafka-consumer</artifactId>
    <version>2.2.1</version>
  </dependency>

  • using on spring boot

# application.yml
goudai:
  kafka:
    consumer:
      bootstrap-servers: ${KAFKA_SERVERS:localhost:9092}
      auto-restart:
        enabled: false # 默认为true 设置为false 表示关闭故障重启
        interval: 20   # 默认间隔20s

/**
* 括号中指定group
*/
@EnableKafka("user-consumer")
public class UserConsumer {
    @KafkaListener(topic = "xxx")
    public void onUserRegisterCouponGranted(ConsumerRecord<String, String> consumerRecord) {
        System.out.println(JsonUtils.toJson(consumerRecord));
    }
}

producer

• add dependency to maven

  <dependency>
     <groupId>io.github.goudai</groupId>
     <artifactId>spring-boot-starter-kafka-producer</artifactId>
    <version>2.2.1</version>
  </dependency>

  • using on spring boot

# application.yml
goudai:
  kafka:
    producer:
      bootstrap-servers: ${KAFKA_SERVERS:localhost:9092}

@Component
public class UserProducer {
    @Autowired
    Producer<String, String> producer;
    public void sendMsg()  {
        producer.send(new ProducerRecord<String, String>("topic","kafkaContext json"));
    }
}