fix examples

Author: rekby

examples/topic/reader_async_example.py

@@ -123,8 +123,8 @@ def process_batch(batch):
                 # no reason work with expired batch
                 # go read next - good batch
                 return
-            await _process(message)
-        await reader.commit(batch)
+            _process(message)
+        reader.commit(batch)
 
     async for batch in reader.batches():
         process_batch(batch)