{"id":101273,"date":"2020-01-09T07:00:43","date_gmt":"2020-01-09T05:00:43","guid":{"rendered":"https:\/\/www.javacodegeeks.com\/?p=101273"},"modified":"2020-01-08T12:33:10","modified_gmt":"2020-01-08T10:33:10","slug":"send-your-data-async-on-kafka","status":"publish","type":"post","link":"https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html","title":{"rendered":"Send your data async on Kafka"},"content":{"rendered":"

For a project, I’m trying to log the basic transactions of the user such as addition and removal of an item and for multiple types of items and sending a message to kafka for each transaction. The accuracy of the log mechanism is not crucial and I don’t want it to block my business code in the case of kafka server downtime. In this case an async approach for sending data to kafka is a better way to go.<\/p>\n

My kafka producer code is in its boot project. For making it async, I just have to add two annotations: @EnableAsync and @Async.<\/p>\n

@EnableAsync will be used in your configuration class (also remember that your class with @SpringBootApplication is also a config class) and will try to find a TaskExecutor bean. If not, it creates a SimpleAsyncTaskExecutor. SimpleAsyncTaskExecutor is ok for toy projects but for anything larger than that it’s a bit risky since it does not limit concurrent threads and does not reuse threads. So to be safe, we will also add a task executor bean.<\/p>\n

So,<\/p>\n

\n
\n\n\n\n
\n
1<\/div>\n
2<\/div>\n
3<\/div>\n
4<\/div>\n
5<\/div>\n
6<\/div>\n<\/td>\n
\n
\n
@SpringBootApplication<\/code><\/div>\n
public<\/code> class<\/code> KafkaUtilsApplication {<\/code><\/div>\n
    <\/code>public<\/code> static<\/code> void<\/code> main(String[] args) {<\/code><\/div>\n
        <\/code>SpringApplication.run(KafkaUtilsApplication.<\/code>class<\/code>, args);<\/code><\/div>\n
    <\/code>}<\/code><\/div>\n
}<\/code><\/div>\n<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n

will become<\/p>\n

\n
\n\n\n\n
\n
01<\/div>\n
02<\/div>\n
03<\/div>\n
04<\/div>\n
05<\/div>\n
06<\/div>\n
07<\/div>\n
08<\/div>\n
09<\/div>\n
10<\/div>\n
11<\/div>\n
12<\/div>\n
13<\/div>\n
14<\/div>\n
15<\/div>\n
16<\/div>\n
17<\/div>\n
18<\/div>\n<\/td>\n
\n
\n
@EnableAsync<\/code><\/div>\n
@SpringBootApplication<\/code><\/div>\n
public<\/code> class<\/code> KafkaUtilsApplication {<\/code><\/div>\n
    <\/code>public<\/code> static<\/code> void<\/code> main(String[] args) {<\/code><\/div>\n
        <\/code>SpringApplication.run(KafkaUtilsApplication.<\/code>class<\/code>, args);<\/code><\/div>\n
    <\/code>}<\/code><\/div>\n
 <\/div>\n
    <\/code>@Bean<\/code><\/div>\n
    <\/code>public<\/code> Executor taskExecutor() {<\/code><\/div>\n
        <\/code>ThreadPoolTaskExecutor executor = <\/code>new<\/code> ThreadPoolTaskExecutor();<\/code><\/div>\n
        <\/code>executor.setCorePoolSize(<\/code>2<\/code>);<\/code><\/div>\n
        <\/code>executor.setMaxPoolSize(<\/code>2<\/code>);<\/code><\/div>\n
        <\/code>executor.setQueueCapacity(<\/code>500<\/code>);<\/code><\/div>\n
        <\/code>executor.setThreadNamePrefix(<\/code>\"KafkaMsgExecutor-\"<\/code>);<\/code><\/div>\n
        <\/code>executor.initialize();<\/code><\/div>\n
        <\/code>return<\/code> executor;<\/code><\/div>\n
    <\/code>}<\/code><\/div>\n
}<\/code><\/div>\n<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n

As you can see there’s not much change here. The default values I set should be tweaked based on your app’s needs.

<\/div> <\/div><\/p>\n

The second thing we need is addition of @Async.<\/p>\n

My old code was:<\/p>\n

\n
\n\n\n\n
\n
01<\/div>\n
02<\/div>\n
03<\/div>\n
04<\/div>\n
05<\/div>\n
06<\/div>\n
07<\/div>\n
08<\/div>\n
09<\/div>\n
10<\/div>\n
11<\/div>\n
12<\/div>\n
13<\/div>\n<\/td>\n
\n
\n
@Service<\/code><\/div>\n
public<\/code> class<\/code> KafkaProducerServiceImpl <\/code>implements<\/code> KafkaProducerService {<\/code><\/div>\n
 <\/div>\n
    <\/code>private<\/code> static<\/code> final<\/code> String TOPIC = <\/code>\"logs\"<\/code>;<\/code><\/div>\n
 <\/div>\n
    <\/code>@Autowired<\/code><\/div>\n
    <\/code>private<\/code> KafkaTemplate<String, KafkaInfo> kafkaTemplate;<\/code><\/div>\n
 <\/div>\n
    <\/code>@Override<\/code><\/div>\n
    <\/code>public<\/code> void<\/code> sendMessage(String id, KafkaType kafkaType, KafkaStatus kafkaStatus) {<\/code><\/div>\n
        <\/code>kafkaTemplate.send(TOPIC, <\/code>new<\/code> KafkaInfo(id, kafkaType, kafkaStatus);<\/code><\/div>\n
    <\/code>}<\/code><\/div>\n
}<\/code><\/div>\n<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n

As you can see the sync code is quite straightforward. It just takes the kafkaTemplate and sends a message object to the “logs” topic. My new code is a bit longer than that.<\/p>\n

\n
\n\n\n\n
\n
01<\/div>\n
02<\/div>\n
03<\/div>\n
04<\/div>\n
05<\/div>\n
06<\/div>\n
07<\/div>\n
08<\/div>\n
09<\/div>\n
10<\/div>\n
11<\/div>\n
12<\/div>\n
13<\/div>\n
14<\/div>\n
15<\/div>\n
16<\/div>\n
17<\/div>\n
18<\/div>\n
19<\/div>\n
20<\/div>\n
21<\/div>\n
22<\/div>\n
23<\/div>\n
24<\/div>\n
25<\/div>\n
26<\/div>\n<\/td>\n
\n
\n
@Service<\/code><\/div>\n
public<\/code> class<\/code> KafkaProducerServiceImpl <\/code>implements<\/code> KafkaProducerService {<\/code><\/div>\n
 <\/div>\n
    <\/code>private<\/code> static<\/code> final<\/code> String TOPIC = <\/code>\"logs\"<\/code>;<\/code><\/div>\n
 <\/div>\n
    <\/code>@Autowired<\/code><\/div>\n
    <\/code>private<\/code> KafkaTemplate kafkaTemplate;<\/code><\/div>\n
 <\/div>\n
    <\/code>@Async<\/code><\/div>\n
    <\/code>@Override<\/code><\/div>\n
    <\/code>public<\/code> void<\/code> sendMessage(String id, KafkaType kafkaType, KafkaStatus kafkaStatus) {<\/code><\/div>\n
        <\/code>ListenableFuture<SendResult<String, KafkaInfo>> future = kafkaTemplate.send(TOPIC, <\/code>new<\/code> KafkaInfo(id, kafkaType, kafkaStatus));<\/code><\/div>\n
        <\/code>future.addCallback(<\/code>new<\/code> ListenableFutureCallback<>() {<\/code><\/div>\n
            <\/code>@Override<\/code><\/div>\n
            <\/code>public<\/code> void<\/code> onSuccess(<\/code>final<\/code> SendResult<String, KafkaInfo> message) {<\/code><\/div>\n
                <\/code>\/\/ left empty intentionally<\/code><\/div>\n
            <\/code>}<\/code><\/div>\n
 <\/div>\n
            <\/code>@Override<\/code><\/div>\n
            <\/code>public<\/code> void<\/code> onFailure(<\/code>final<\/code> Throwable throwable) {<\/code><\/div>\n
                <\/code>\/\/ left empty intentionally<\/code><\/div>\n
 <\/div>\n
            <\/code>}<\/code><\/div>\n
        <\/code>});<\/code><\/div>\n
    <\/code>}<\/code><\/div>\n
}<\/code><\/div>\n<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n

Here onSuccess() is not really meaningful for me. But onFailure() I can log the exception so I’m informed if there’s a problem with my kafka server.<\/p>\n

There’s another thing I have to share with you. For sending an object through kafkatemplate, I have to equip it with the serializer file I have.<\/p>\n

\n
\n\n\n\n
\n
01<\/div>\n
02<\/div>\n
03<\/div>\n
04<\/div>\n
05<\/div>\n
06<\/div>\n
07<\/div>\n
08<\/div>\n
09<\/div>\n
10<\/div>\n
11<\/div>\n
12<\/div>\n
13<\/div>\n
14<\/div>\n
15<\/div>\n
16<\/div>\n
17<\/div>\n
18<\/div>\n
19<\/div>\n
20<\/div>\n
21<\/div>\n
22<\/div>\n<\/td>\n
\n
\n
public<\/code> class<\/code> KafkaInfoSerializer <\/code>implements<\/code> Serializer<kafkainfo> {<\/code><\/div>\n
 <\/div>\n
    <\/code>@Override<\/code><\/div>\n
    <\/code>public<\/code> void<\/code> configure(Map map, <\/code>boolean<\/code> b) {<\/code><\/div>\n
    <\/code>}<\/code><\/div>\n
 <\/div>\n
    <\/code>@Override<\/code><\/div>\n
    <\/code>public<\/code> byte<\/code>[] serialize(String arg0, KafkaInfo info) {<\/code><\/div>\n
        <\/code>byte<\/code>[] retVal = <\/code>null<\/code>;<\/code><\/div>\n
        <\/code>ObjectMapper objectMapper = <\/code>new<\/code> ObjectMapper();<\/code><\/div>\n
        <\/code>try<\/code> {<\/code><\/div>\n
            <\/code>retVal = objectMapper.writeValueAsString(info).getBytes();<\/code><\/div>\n
        <\/code>} <\/code>catch<\/code> (Exception e) {<\/code><\/div>\n
            <\/code>\/\/ log the exception<\/code><\/div>\n
        <\/code>}<\/code><\/div>\n
        <\/code>return<\/code> retVal;<\/code><\/div>\n
    <\/code>}<\/code><\/div>\n
 <\/div>\n
    <\/code>@Override<\/code><\/div>\n
    <\/code>public<\/code> void<\/code> close() {<\/code><\/div>\n
    <\/code>}<\/code><\/div>\n
}<\/code><\/div>\n<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n

Also, don’t forget to add the configuration for it. There are several ways of defining serializers for kafka. One of the easiest ways is adding it to application.properties. <\/p>\n

spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer spring.kafka.producer.value-serializer=com.sezinkarli.kafkautils.serializer.KafkaInfoSerializer<\/p>\n

Now you have a boot project that can send async objects to the desired topic.<\/p>\n

\n\n\n\n
\n

Published on Java Code Geeks with permission by Sezin Karli, partner at our JCG program<\/a>. See the original article here: send your data async on kafka<\/a><\/p>\n

Opinions expressed by Java Code Geeks contributors are their own.<\/p>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n","protected":false},"excerpt":{"rendered":"

For a project, I’m trying to log the basic transactions of the user such as addition and removal of an item and for multiple types of items and sending a message to kafka for each transaction. The accuracy of the log mechanism is not crucial and I don’t want it to block my business code …<\/p>\n","protected":false},"author":555,"featured_media":240,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[8],"tags":[1349,30,854],"class_list":["post-101273","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-enterprise-java","tag-kafka","tag-spring","tag-spring-boot"],"yoast_head":"\nSend your data async on Kafka - Java Code Geeks<\/title>\n<meta name=\"description\" content=\"Interested to learn about data async? Check our article explaining how to send a message to kafka for each transaction with examples.\" \/>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html\" \/>\n<meta property=\"og:locale\" content=\"en_US\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"Send your data async on Kafka - Java Code Geeks\" \/>\n<meta property=\"og:description\" content=\"Interested to learn about data async? Check our article explaining how to send a message to kafka for each transaction with examples.\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html\" \/>\n<meta property=\"og:site_name\" content=\"Java Code Geeks\" \/>\n<meta property=\"article:publisher\" content=\"https:\/\/www.facebook.com\/javacodegeeks\" \/>\n<meta property=\"article:published_time\" content=\"2020-01-09T05:00:43+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2012\/10\/spring-logo.jpg\" \/>\n\t<meta property=\"og:image:width\" content=\"150\" \/>\n\t<meta property=\"og:image:height\" content=\"150\" \/>\n\t<meta property=\"og:image:type\" content=\"image\/jpeg\" \/>\n<meta name=\"author\" content=\"Sezin Karli\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:creator\" content=\"@http:\/\/www.twitter.com\/sezin_karli\" \/>\n<meta name=\"twitter:site\" content=\"@javacodegeeks\" \/>\n<meta name=\"twitter:label1\" content=\"Written by\" \/>\n\t<meta name=\"twitter:data1\" content=\"Sezin Karli\" \/>\n\t<meta name=\"twitter:label2\" content=\"Est. reading time\" \/>\n\t<meta name=\"twitter:data2\" content=\"5 minutes\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\\\/\\\/schema.org\",\"@graph\":[{\"@type\":\"Article\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2020\\\/01\\\/send-your-data-async-on-kafka.html#article\",\"isPartOf\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2020\\\/01\\\/send-your-data-async-on-kafka.html\"},\"author\":{\"name\":\"Sezin Karli\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#\\\/schema\\\/person\\\/0708f042fa1ff1bfe8199d95e1a9c360\"},\"headline\":\"Send your data async on Kafka\",\"datePublished\":\"2020-01-09T05:00:43+00:00\",\"mainEntityOfPage\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2020\\\/01\\\/send-your-data-async-on-kafka.html\"},\"wordCount\":426,\"commentCount\":3,\"publisher\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#organization\"},\"image\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2020\\\/01\\\/send-your-data-async-on-kafka.html#primaryimage\"},\"thumbnailUrl\":\"https:\\\/\\\/www.javacodegeeks.com\\\/wp-content\\\/uploads\\\/2012\\\/10\\\/spring-logo.jpg\",\"keywords\":[\"Kafka\",\"Spring\",\"Spring Boot\"],\"articleSection\":[\"Enterprise Java\"],\"inLanguage\":\"en-US\",\"potentialAction\":[{\"@type\":\"CommentAction\",\"name\":\"Comment\",\"target\":[\"https:\\\/\\\/www.javacodegeeks.com\\\/2020\\\/01\\\/send-your-data-async-on-kafka.html#respond\"]}]},{\"@type\":\"WebPage\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2020\\\/01\\\/send-your-data-async-on-kafka.html\",\"url\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2020\\\/01\\\/send-your-data-async-on-kafka.html\",\"name\":\"Send your data async on Kafka - Java Code Geeks\",\"isPartOf\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#website\"},\"primaryImageOfPage\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2020\\\/01\\\/send-your-data-async-on-kafka.html#primaryimage\"},\"image\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2020\\\/01\\\/send-your-data-async-on-kafka.html#primaryimage\"},\"thumbnailUrl\":\"https:\\\/\\\/www.javacodegeeks.com\\\/wp-content\\\/uploads\\\/2012\\\/10\\\/spring-logo.jpg\",\"datePublished\":\"2020-01-09T05:00:43+00:00\",\"description\":\"Interested to learn about data async? Check our article explaining how to send a message to kafka for each transaction with examples.\",\"breadcrumb\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2020\\\/01\\\/send-your-data-async-on-kafka.html#breadcrumb\"},\"inLanguage\":\"en-US\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\\\/\\\/www.javacodegeeks.com\\\/2020\\\/01\\\/send-your-data-async-on-kafka.html\"]}]},{\"@type\":\"ImageObject\",\"inLanguage\":\"en-US\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2020\\\/01\\\/send-your-data-async-on-kafka.html#primaryimage\",\"url\":\"https:\\\/\\\/www.javacodegeeks.com\\\/wp-content\\\/uploads\\\/2012\\\/10\\\/spring-logo.jpg\",\"contentUrl\":\"https:\\\/\\\/www.javacodegeeks.com\\\/wp-content\\\/uploads\\\/2012\\\/10\\\/spring-logo.jpg\",\"width\":150,\"height\":150,\"caption\":\"spring-interview-questions-answers\"},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2020\\\/01\\\/send-your-data-async-on-kafka.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"Home\",\"item\":\"https:\\\/\\\/www.javacodegeeks.com\\\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"Java\",\"item\":\"https:\\\/\\\/www.javacodegeeks.com\\\/category\\\/java\"},{\"@type\":\"ListItem\",\"position\":3,\"name\":\"Enterprise Java\",\"item\":\"https:\\\/\\\/www.javacodegeeks.com\\\/category\\\/java\\\/enterprise-java\"},{\"@type\":\"ListItem\",\"position\":4,\"name\":\"Send your data async on Kafka\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#website\",\"url\":\"https:\\\/\\\/www.javacodegeeks.com\\\/\",\"name\":\"Java Code Geeks\",\"description\":\"Java Developers Resource Center\",\"publisher\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#organization\"},\"alternateName\":\"JCG\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\\\/\\\/www.javacodegeeks.com\\\/?s={search_term_string}\"},\"query-input\":{\"@type\":\"PropertyValueSpecification\",\"valueRequired\":true,\"valueName\":\"search_term_string\"}}],\"inLanguage\":\"en-US\"},{\"@type\":\"Organization\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#organization\",\"name\":\"Exelixis Media P.C.\",\"url\":\"https:\\\/\\\/www.javacodegeeks.com\\\/\",\"logo\":{\"@type\":\"ImageObject\",\"inLanguage\":\"en-US\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#\\\/schema\\\/logo\\\/image\\\/\",\"url\":\"https:\\\/\\\/www.javacodegeeks.com\\\/wp-content\\\/uploads\\\/2022\\\/06\\\/exelixis-logo.png\",\"contentUrl\":\"https:\\\/\\\/www.javacodegeeks.com\\\/wp-content\\\/uploads\\\/2022\\\/06\\\/exelixis-logo.png\",\"width\":864,\"height\":246,\"caption\":\"Exelixis Media P.C.\"},\"image\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#\\\/schema\\\/logo\\\/image\\\/\"},\"sameAs\":[\"https:\\\/\\\/www.facebook.com\\\/javacodegeeks\",\"https:\\\/\\\/x.com\\\/javacodegeeks\"]},{\"@type\":\"Person\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#\\\/schema\\\/person\\\/0708f042fa1ff1bfe8199d95e1a9c360\",\"name\":\"Sezin Karli\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"en-US\",\"@id\":\"https:\\\/\\\/secure.gravatar.com\\\/avatar\\\/1967bcfd8aa8a21d58a7354d871541385d56bc6ffbe4238a7c0f1341d2e5ebd8?s=96&d=mm&r=g\",\"url\":\"https:\\\/\\\/secure.gravatar.com\\\/avatar\\\/1967bcfd8aa8a21d58a7354d871541385d56bc6ffbe4238a7c0f1341d2e5ebd8?s=96&d=mm&r=g\",\"contentUrl\":\"https:\\\/\\\/secure.gravatar.com\\\/avatar\\\/1967bcfd8aa8a21d58a7354d871541385d56bc6ffbe4238a7c0f1341d2e5ebd8?s=96&d=mm&r=g\",\"caption\":\"Sezin Karli\"},\"description\":\"Mathematics Engineer & Computer Scientist with a passion for software development. Avid learner for new technologies. Currently working as Senior Software Engineer at Sahibinden.com.\",\"sameAs\":[\"http:\\\/\\\/blog.sezinkarli.com\\\/\",\"http:\\\/\\\/tr.linkedin.com\\\/in\\\/skarli\",\"https:\\\/\\\/x.com\\\/http:\\\/\\\/www.twitter.com\\\/sezin_karli\"],\"url\":\"https:\\\/\\\/www.javacodegeeks.com\\\/author\\\/sezin-karli\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"Send your data async on Kafka - Java Code Geeks","description":"Interested to learn about data async? Check our article explaining how to send a message to kafka for each transaction with examples.","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html","og_locale":"en_US","og_type":"article","og_title":"Send your data async on Kafka - Java Code Geeks","og_description":"Interested to learn about data async? Check our article explaining how to send a message to kafka for each transaction with examples.","og_url":"https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html","og_site_name":"Java Code Geeks","article_publisher":"https:\/\/www.facebook.com\/javacodegeeks","article_published_time":"2020-01-09T05:00:43+00:00","og_image":[{"width":150,"height":150,"url":"https:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2012\/10\/spring-logo.jpg","type":"image\/jpeg"}],"author":"Sezin Karli","twitter_card":"summary_large_image","twitter_creator":"@http:\/\/www.twitter.com\/sezin_karli","twitter_site":"@javacodegeeks","twitter_misc":{"Written by":"Sezin Karli","Est. reading time":"5 minutes"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"Article","@id":"https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html#article","isPartOf":{"@id":"https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html"},"author":{"name":"Sezin Karli","@id":"https:\/\/www.javacodegeeks.com\/#\/schema\/person\/0708f042fa1ff1bfe8199d95e1a9c360"},"headline":"Send your data async on Kafka","datePublished":"2020-01-09T05:00:43+00:00","mainEntityOfPage":{"@id":"https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html"},"wordCount":426,"commentCount":3,"publisher":{"@id":"https:\/\/www.javacodegeeks.com\/#organization"},"image":{"@id":"https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html#primaryimage"},"thumbnailUrl":"https:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2012\/10\/spring-logo.jpg","keywords":["Kafka","Spring","Spring Boot"],"articleSection":["Enterprise Java"],"inLanguage":"en-US","potentialAction":[{"@type":"CommentAction","name":"Comment","target":["https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html#respond"]}]},{"@type":"WebPage","@id":"https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html","url":"https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html","name":"Send your data async on Kafka - Java Code Geeks","isPartOf":{"@id":"https:\/\/www.javacodegeeks.com\/#website"},"primaryImageOfPage":{"@id":"https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html#primaryimage"},"image":{"@id":"https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html#primaryimage"},"thumbnailUrl":"https:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2012\/10\/spring-logo.jpg","datePublished":"2020-01-09T05:00:43+00:00","description":"Interested to learn about data async? Check our article explaining how to send a message to kafka for each transaction with examples.","breadcrumb":{"@id":"https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html#breadcrumb"},"inLanguage":"en-US","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html"]}]},{"@type":"ImageObject","inLanguage":"en-US","@id":"https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html#primaryimage","url":"https:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2012\/10\/spring-logo.jpg","contentUrl":"https:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2012\/10\/spring-logo.jpg","width":150,"height":150,"caption":"spring-interview-questions-answers"},{"@type":"BreadcrumbList","@id":"https:\/\/www.javacodegeeks.com\/2020\/01\/send-your-data-async-on-kafka.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"Home","item":"https:\/\/www.javacodegeeks.com\/"},{"@type":"ListItem","position":2,"name":"Java","item":"https:\/\/www.javacodegeeks.com\/category\/java"},{"@type":"ListItem","position":3,"name":"Enterprise Java","item":"https:\/\/www.javacodegeeks.com\/category\/java\/enterprise-java"},{"@type":"ListItem","position":4,"name":"Send your data async on Kafka"}]},{"@type":"WebSite","@id":"https:\/\/www.javacodegeeks.com\/#website","url":"https:\/\/www.javacodegeeks.com\/","name":"Java Code Geeks","description":"Java Developers Resource Center","publisher":{"@id":"https:\/\/www.javacodegeeks.com\/#organization"},"alternateName":"JCG","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.javacodegeeks.com\/?s={search_term_string}"},"query-input":{"@type":"PropertyValueSpecification","valueRequired":true,"valueName":"search_term_string"}}],"inLanguage":"en-US"},{"@type":"Organization","@id":"https:\/\/www.javacodegeeks.com\/#organization","name":"Exelixis Media P.C.","url":"https:\/\/www.javacodegeeks.com\/","logo":{"@type":"ImageObject","inLanguage":"en-US","@id":"https:\/\/www.javacodegeeks.com\/#\/schema\/logo\/image\/","url":"https:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2022\/06\/exelixis-logo.png","contentUrl":"https:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2022\/06\/exelixis-logo.png","width":864,"height":246,"caption":"Exelixis Media P.C."},"image":{"@id":"https:\/\/www.javacodegeeks.com\/#\/schema\/logo\/image\/"},"sameAs":["https:\/\/www.facebook.com\/javacodegeeks","https:\/\/x.com\/javacodegeeks"]},{"@type":"Person","@id":"https:\/\/www.javacodegeeks.com\/#\/schema\/person\/0708f042fa1ff1bfe8199d95e1a9c360","name":"Sezin Karli","image":{"@type":"ImageObject","inLanguage":"en-US","@id":"https:\/\/secure.gravatar.com\/avatar\/1967bcfd8aa8a21d58a7354d871541385d56bc6ffbe4238a7c0f1341d2e5ebd8?s=96&d=mm&r=g","url":"https:\/\/secure.gravatar.com\/avatar\/1967bcfd8aa8a21d58a7354d871541385d56bc6ffbe4238a7c0f1341d2e5ebd8?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/1967bcfd8aa8a21d58a7354d871541385d56bc6ffbe4238a7c0f1341d2e5ebd8?s=96&d=mm&r=g","caption":"Sezin Karli"},"description":"Mathematics Engineer & Computer Scientist with a passion for software development. Avid learner for new technologies. Currently working as Senior Software Engineer at Sahibinden.com.","sameAs":["http:\/\/blog.sezinkarli.com\/","http:\/\/tr.linkedin.com\/in\/skarli","https:\/\/x.com\/http:\/\/www.twitter.com\/sezin_karli"],"url":"https:\/\/www.javacodegeeks.com\/author\/sezin-karli"}]}},"_links":{"self":[{"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/posts\/101273","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/users\/555"}],"replies":[{"embeddable":true,"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/comments?post=101273"}],"version-history":[{"count":0,"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/posts\/101273\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/media\/240"}],"wp:attachment":[{"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/media?parent=101273"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/categories?post=101273"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/tags?post=101273"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}