java - Spring Cloud Stream send to Kafka error control handling -


how catch error writing kafka topic? 

import org.springframework.cloud.stream.annotation.enablebinding; import org.springframework.cloud.stream.annotation.streamlistener; import org.springframework.cloud.stream.messaging.processor; import org.springframework.messaging.message; import org.springframework.messaging.handler.annotation.sendto; import org.springframework.stereotype.component;  import javax.xml.bind.jaxbexception;  @component @enablebinding(processor.class) public class parser {      @streamlistener(processor.input)     @sendto(processor.output)     public string process(message<?> input) {          // smth          // how catch error if sending message 'output' topic fails     }  }

switch producer synchronous mode.

spring.cloud.stream.kafka.bindings.output.producer.sync=true

what next? examples? extend binding impl, add aop magic?

i think need register kafkaproducerlistener handles error scenario in case , make available bean in application.

for more info on kafkaproducerlistener here

also, note failed messages available on errorchannel channel name error. error messages published once have configure destination name error channel: spring.cloud.stream.bindings.error.destination.


-

Comments

Post a Comment

Popular posts from this blog

java - SSE Emitter : Manage timeouts and complete() -

i writing web app multiple listeners(evcentsource sse clients js) connected server . want store sse emitter per connected listener : can done in memory or other means assigning id each client able achieve far now question ; how send response/event specific client connected web app ? while doing sseemmiters stored either getting completed or timed out. how prevent ? how keep sseemmiter available open infinite time (till client closes) , send events selectively .
Read more

jquery - uncaught exception: DataTables Editor - remote hosting of code not allowed -

i'm trying implement crud operation using datatableseditor using datatables.but i'm getting error messages: 1)uncaught exception: datatables editor - remote hosting of code not allowed. please see http://editor.datatables.net details on how purchase editor license 2)typeerror: a.editor undefined 3) $.fn.datatable.editor not constructor" what reason? here configuration: <%@ page language="java" contenttype="text/html; charset=iso-8859-1" pageencoding="iso-8859-1"%> <!doctype html public "-//w3c//dtd html 4.01 transitional//en" "http://www.w3.org/tr/html4/loose.dtd"> <html> <head> <meta http-equiv="content-type" content="text/html; charset=iso-8859-1"> <title>insert title here</title> <link rel="stylesheet" type="text/css" href="//cdn.datatables.net/1.10.12/css/jquery.datatables.min.css"> <link re...
Read more

java - InvalidDataAccessApiUsageException: Parameter value element did not match expected type -

i'm trying execute in query using spring data. model looks this: @entity @table(name = "customer", schema = "public", catalog = "postgres") public class customerentity { private int id; private string name; private int balance; private string bankid; @id @column(name = "id") public int getid() { return id; } public void setid(int id) { this.id = id; } @basic @column(name = "name") public string getname() { return name; } public void setname(string name) { this.name = name; } @basic @column(name = "balance") public int getbalance() { return balance; } public void setbalance(int balance) { this.balance = balance; } @basic @column(name = "bank_id") public string getbankid() { return bankid; } public void setbankid(string bankid) { th...
Read more