{"action":"closed","issue":{"url":"https://api.github.com/repos/CrossRef/event-data-percolator/issues/55","repository_url":"https://api.github.com/repos/CrossRef/event-data-percolator","labels_url":"https://api.github.com/repos/CrossRef/event-data-percolator/issues/55/labels{/name}","comments_url":"https://api.github.com/repos/CrossRef/event-data-percolator/issues/55/comments","events_url":"https://api.github.com/repos/CrossRef/event-data-percolator/issues/55/events","html_url":"https://github.com/CrossRef/event-data-percolator/issues/55","id":237564331,"number":55,"title":"Switch to Apache Kafka","user":{"login":"afandian","id":389345,"avatar_url":"https://avatars0.githubusercontent.com/u/389345?v=4","gravatar_id":"","url":"https://api.github.com/users/afandian","html_url":"https://github.com/afandian","followers_url":"https://api.github.com/users/afandian/followers","following_url":"https://api.github.com/users/afandian/following{/other_user}","gists_url":"https://api.github.com/users/afandian/gists{/gist_id}","starred_url":"https://api.github.com/users/afandian/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/afandian/subscriptions","organizations_url":"https://api.github.com/users/afandian/orgs","repos_url":"https://api.github.com/users/afandian/repos","events_url":"https://api.github.com/users/afandian/events{/privacy}","received_events_url":"https://api.github.com/users/afandian/received_events","type":"User","site_admin":false},"labels":[],"state":"closed","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":0,"created_at":"2017-06-21T14:57:43Z","updated_at":"2017-09-28T15:50:34Z","closed_at":"2017-09-28T15:50:34Z","author_association":"OWNER","body":"Integrate Apache Kafka into workflow. Has implications for Agents (event-data-agent-framework) and Event Bus.\r\n\r\n - ditch ActiveMQ\r\n - accept inputs from a Topic\r\n - remove Accept stage (keep code around but don't use it in normal flow)\r\n - remove time-stamping and IDing from Process stage, instead make Agents supply this\r\n - move all processing into `process` stage, including sending Events to Bus and storing Evidence Records\r\n - don't HTTP POST to bus, instead send to a Topic and Bus should pick the data up\r\n - check for existence of Evidence Record before processing, so we're tolerant of duplicate inputs and can happily skip them"}}
{"actor":{"display_login":"afandian"}}