この辺とか読みながら→ Introduction — Confluent Platform 3.1.0 documentation Twitter4Jで適当に英語のツイートをとってきて、Kafkaに流し込む。(キーとかの設定はtwitter4j.propertiesに入れておいた) @Component public class TwitterToKafka implements CommandLineRunner { @Autowired private KafkaTemplate<String, String> template; @Override public void run(String... args) throws Exception { TwitterStream twitterStream = new TwitterStreamFactory().getInstance