preference.put("publisherMaxBatchSize", "1000");
preference.put("publisherMaxRecoveryQueueSize", "100");
preference.put("publisherPollingInterval", "6000");
preference.put("publisherMaxBatchSize", "1000");
preference.put("publisherMaxRecoveryQueueSize", "100");
preference.put("publisherPollingInterval", "6000");