package com.idea.kafka;

import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;

@Component
@AllArgsConstructor
public class KafkaProducer {

    private static final Logger log = LoggerFactory.getLogger(KafkaProducer.class);

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    public void sendData(String data){

        try {
            for (int i = 0; i < 10; i++)
            {
                kafkaTemplate.send("test", "这是测试的数据==> "+data+" i ="+i );
                Thread.sleep(1000);
            }

        }catch (Exception e){
            e.printStackTrace();
            log.error("出错！！！！！！！！！！！");
        }

    }

}