Please enable JavaScript.

Coggle requires JavaScript to display documents.

Kafka (producer (sending mechanism (fire & forget (e.g.…

- - - - e.g.
        
        ProducerRecord<String,String> record = new ProducerRecord("Customer Country", "Precision products", "France") try { producer.send(record); } catch (Exception e) { e.printStackTrace(); }
    - - e.g.
        
        Just add producer.send(record).get(); #
    - - e.g.
        
        private class ReportingCallback implements Callback { @Override public void onComplete(RecordMetadata recordMetadata, Exception e) { if(e != null) { e.printStackTrace(); } } ... ... producer.send(record, new ReportingCallback());
  - - - e.g.
        
        ProducerRecord<String,String> record = new ProducerRecord("Customer Country", "Precision products", "France")
        
        Topic name (String)
        
        Key name (String, in this case?)
        
        Value name (String, in this case?)
  - - - e.g.
        
        no leader available, but can wait for election
        
        no connection, but can wait for connection to be made
      - only if number of retries are more than threshold
    - - like, message size to large
  - - - 0 - don't wait. send at highest possible n/w throughput
      - 1 - some form of ack (not safest)
      - 2 - safest, slowest