{"action":"opened","issue":{"url":"https://api.github.com/repos/aserrallerios/kcl-akka-stream/issues/7","repository_url":"https://api.github.com/repos/aserrallerios/kcl-akka-stream","labels_url":"https://api.github.com/repos/aserrallerios/kcl-akka-stream/issues/7/labels{/name}","comments_url":"https://api.github.com/repos/aserrallerios/kcl-akka-stream/issues/7/comments","events_url":"https://api.github.com/repos/aserrallerios/kcl-akka-stream/issues/7/events","html_url":"https://github.com/aserrallerios/kcl-akka-stream/issues/7","id":351603098,"node_id":"MDU6SXNzdWUzNTE2MDMwOTg=","number":7,"title":"Error in README.md","user":{"login":"Pierre1405","id":27217577,"node_id":"MDQ6VXNlcjI3MjE3NTc3","avatar_url":"https://avatars0.githubusercontent.com/u/27217577?v=4","gravatar_id":"","url":"https://api.github.com/users/Pierre1405","html_url":"https://github.com/Pierre1405","followers_url":"https://api.github.com/users/Pierre1405/followers","following_url":"https://api.github.com/users/Pierre1405/following{/other_user}","gists_url":"https://api.github.com/users/Pierre1405/gists{/gist_id}","starred_url":"https://api.github.com/users/Pierre1405/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/Pierre1405/subscriptions","organizations_url":"https://api.github.com/users/Pierre1405/orgs","repos_url":"https://api.github.com/users/Pierre1405/repos","events_url":"https://api.github.com/users/Pierre1405/events{/privacy}","received_events_url":"https://api.github.com/users/Pierre1405/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":0,"created_at":"2018-08-17T13:51:35Z","updated_at":"2018-08-17T13:51:35Z","closed_at":null,"author_association":"NONE","body":"Hi,\r\n\r\nI just notice a small error in the code example:\r\n```scala\r\nval checkpointSettings = KinesisWorkerCheckpointSettings(100, 30 seconds)\r\n\r\nKinesisWorkerSource(builder, workerSourceSettings)\r\n  .via(KinesisWorker.checkpointRecordsFlow(checkpointSettings))\r\n  .to(Sink.ignore)\r\n\r\nKinesisWorkerSource(builder, workerSourceSettings).to(\r\n  KinesisWorker.checkpointRecordsSink(checkpointSettings))\r\n```\r\nshould be\r\n```scala\r\nval checkpointSettings = KinesisWorkerCheckpointSettings(100, 30 seconds)\r\n\r\nKinesisWorkerSource(builder, workerSourceSettings)\r\n  .via(KinesisWorkerSource.checkpointRecordsFlow(checkpointSettings))\r\n  .to(Sink.ignore)\r\n\r\nKinesisWorkerSource(builder, workerSourceSettings).to(\r\n  KinesisWorkerSource.checkpointRecordsSink(checkpointSettings))\r\n```\r\nTake care and thanks for sharing your code\r\n\r\nPierre"}}
{"actor":{"display_login":"Pierre1405"}}