Android code to post data to that Kinesis Stream

android_post_kinesis_stream.java

import com.amazonaws.auth.CognitoCachingCredentialsProvider;
import com.amazonaws.mobileconnectors.kinesis.kinesisrecorder.KinesisRecorder;

File directory = getApplicationContext().getCacheDir();
CognitoCachingCredentialsProvider credentialsProvider = new CognitoCachingCredentialsProvider(getApplicationContext(), "Identity pool ID", Regions.US_WEST_2);
KinesisRecorder kinesisRecorder = new KinesisRecorder(directory, Regions.US_WEST_2, credentialsProvider);
String kinesisStreamName = "test2-kinesis-data-stream";

JSONObject json = new JSONObject();
try {
   json.accumulate("rpm", vehicleStats.getRpm());
   json.accumulate("speed", vehicleStats.getSpeed());
   json.accumulate("fuel", vehicleStats.getFuel());
   json.accumulate("distance", vehicleStats.getDistance());
   json.accumulate("vin", vehicleStats.getVin());
   json.accumulate("dtc", vehicleStats.getDtc());
   json.accumulate("timestamp", vehicleStats.getTimestamp());
   kinesisRecorder.saveRecord(json.toString(), kinesisStreamName);
   new AsyncTask<Void, Void, Void>() {
       @Override
       protected Void doInBackground(Void... v) {
           try {
               kinesisRecorder.submitAllRecords();
           } catch (AmazonClientException ace) {
               Log.e(TAG, "Error = " + ace.getMessage());
           }
           return null;
       }
   }.execute();
} catch (Exception e) {
   Log.e(TAG, "Error = " + e.getMessage());
}