Learig
ThisprojectisacompaiorepositorytotheApacheKafkaCoectcourseoUdemy.
https://liks.datacumulus.com/kafka-coect-coupo
KafkaCoectSourceGitHubThiscoectorallowsyoutogetastreamofissuesadpullrequestsfromyourGitHubrepository,usigtheGitHubApi:https://developer.github.com/v3/issues/#list-issues-for-a-repository
Issuesarepulledbasedoupdated_atfield,meaigayupdatetoaissueorpullrequestwillappearithestream.
Thecoectorwritestotopicthatisgreatcadidatetodemostratelogcompactio.It'salsoafuwaytoautomateyourGitHubworkflow.
It'sfiallyaimedtobeaeducativeexampletodemostratehowtowriteaSourceCoectoralittlelesstrivialthatheFileStreamSourceCoectorprovidediKafka.
CotributigThiscoectorisotperfectadcabeimproved,pleasefeelfreetosubmitayPRyoudeemuseful.
Cofiguratioame=GitHubSourceCoectorDemotasks.max=1coector.class=com.simplesteph.kafka.GitHubSourceCoectortopic=github-issuesgithub.ower=kuberetesgithub.repo=kuberetessice.timestamp=2017-01-01T00:00:00Z#Iheavilyrecommedyousetthosetwofields:auth.userame=your_userameauth.password=your_passwordRuigidevelopmetNote:Java8isrequiredforthiscoector.Makesurecofig/worker.propertiesiscofiguredtowhereveryourkafkaclusteris
./build.sh./ru.shThesimplestwaytoruru.shistohavedockeristalled.ItwillpullaDockerfileadruthecoectoristadaloemodeaboveit.
DeployigNote:Java8isrequiredforthiscoector.
TODO










评论