проблема с кодом библиотеки Kinesis Producer - PullRequest
Новая
       26

проблема с кодом библиотеки Kinesis Producer

0 голосов
/ 21 апреля 2019

Я пытаюсь собрать своего первого производителя и попытался скопировать пример кода из amazon (отвечая на результаты асинхронно): https://docs.aws.amazon.com/streams/latest/dev/kinesis-kpl-writing.html

Но, похоже, в цикле for возникает ошибка,говорит неожиданный знак.Что я делаю не так?

Я перепробовал все решения (которые я нашел в stackoverflow), в которых говорится об этой проблеме, но ни одно из них не помогло.

Вот код amazon (я скопировалэто в основной класс): 

KinesisProducer kinesis = new KinesisProducer();

FutureCallback<UserRecordResult> myCallback = new 
FutureCallback<UserRecordResult>() {     
    @Override public void onFailure(Throwable t) {
        /* Analyze and respond to the failure  */ 
    };     
    @Override public void onSuccess(UserRecordResult result) { 
        /* Respond to the success */ 
    };
};

for (int i = 0; i < 100; ++i) {
    ByteBuffer data = ByteBuffer.wrap("myData".getBytes("UTF-8"));      
    ListenableFuture<UserRecordResult> f = 
kinesis.addUserRecord("myStream", "myPartitionKey", data);     
    // If the Future is complete by the time we call addCallback, the 
callback will be invoked immediately.
    Futures.addCallback(f, myCallback); 
}
...