public void produceIntegers(String topic,int messageCount,int initialValue,Runnable completionCallback){
  AtomicLong counter=new AtomicLong(initialValue);
  produceIntegers(messageCount,completionCallback,null);
}

public void produceIntegers ( String topic , int messageCount , int initialValue , Runnable completionCallback ) { AtomicLong counter = new AtomicLong ( initialValue ) ; produceIntegers ( messageCount , completionCallback , null ) ; }
asynchronously produce messages with string keys and sequential integer values , and write them to the cluster .
