< dependencyManagement >< >的依赖关系<依赖>< groupId >org.apache.camel< / groupId >< artifactId >camel-bom< / artifactId ><版本>$ {version.camel}> < /版本<类型>砰的一声> < /类型< >范围进口< / >范围< / >的依赖<！——使用所需的Debezium版开云体育官方注册网址本——><依赖>< groupId >io.开云体育官方注册网址debezium< / groupId >< artifactId >开云体育官方注册网址debezium-connector-postgres< / artifactId ><版本>$ {version开云体育官方注册网址.debezium}> < /版本< / >的依赖<依赖>< groupId >io.开云体育官方注册网址debezium< / groupId >< artifactId >开云体育官方注册网址debezium-embedded< / artifactId ><版本>$ {version开云体育官方注册网址.debezium}> < /版本< / >的依赖<依赖>< groupId >io.开云体育官方注册网址debezium< / groupId >< artifactId >开云体育官方注册网址debezium-core< / artifactId ><版本>$ {version开云体育官方注册网址.debezium}> < /版本< / >的依赖< / >的依赖关系< / dependencyManagement >< >的依赖关系<依赖>< groupId >org.apache.camel< / groupId >< artifactId >camel-core< / artifactId >< / >的依赖<依赖>< groupId >org.apache.camel< / groupId >< artifactId >camel-开云体育官方注册网址debezium-postgres< / artifactId >< / >的依赖< / >的依赖关系

公共类Qa开云体育电动老虎机DatabaseUserNotifier扩展RouteBuilder {@Override公共无效配置()抛出异常{(＂开云体育官方注册网址debezium-postgres: localhost ?＂+＂开云体育电动老虎机databaseHostname = {{database.hostname}}＂+＂&开云体育电动老虎机databasePort = {{database.port}}＂+＂&开云体育电动老虎机databaseUser = {{database.user}}＂+＂&开云体育电动老虎机databasePassword = {{database.password}}＂+＂&开云体育电动老虎机databaseDbname = postgres＂+＂&开云体育电动老虎机databaseServerName = qa＂+＂&schemaWhitelist = 开云体育电动老虎机{{database.schema}}＂+＂&tableWhitelist = 开云体育电动老虎机{{database.schema}} .question, {{database.schema}} .answer＂+＂&offsetStorage = org.apache.kafka.connect.storage.MemoryOffsetBackingStore＂) .routeId(Qa开云体育电动老虎机DatabaseUserNotifier.class.getName() +＂.开云体育电动老虎机DatabaseReader＂）(1）. log (LoggingLevel.DEBUG＂传入消息${body}带有标题${headers}＂) .choice ()（2）当(isQuestionEvent) .filter (isCreateOrUpdateEvent)（3）.convertBodyTo (Question.class)（4）. log (LoggingLevel.TRACE＂转换为逻辑类${body}＂) .bean(商店,＂readFromStoreAndUpdateIfNeeded＂）（5）文(ROUTE_MAIL_QUESTION_CREATE)(6）.endChoice() .when(isAnswerEvent) .filter(isCreateOrUpdateEvent) .convertBodyTo(Answer.class) .log(LoggingLevel.TRACE，＂转换为逻辑类${body}＂) .bean(商店,＂readFromStoreAndAddAnswer＂) .to(ROUTE_MAIL_ANSWER_CHANGE) .filter(hasManyAnswers)(7）.setBody () .simple (＂问题“$ {exchangeProperty(聚合)。文本}”＂+＂许多答案(生成于＂+ Instant.now() +＂）＂) .to(TWITTER_SERVER) .end() .endChoice() . else () .log(LoggingLevel.WARN，＂未知类型${headers[＂+ 开云体育官方注册网址DebeziumConstants。HEADER_IDENTIFIER +＂]}＂) .endParent ();从(ROUTE_MAIL_QUESTION_CREATE)(6）.routeId (Q开云体育电动老虎机aDatabaseUserNotifier.class.getName () +＂.QuestionNotifier＂) .setHeader (＂来＂) .simple (＂$ {body.email}＂) .setHeader (＂主题＂) .simple (＂创建/编辑的问题＂) .setBody () .simple (＂“${身体问题。文本｝' was created or edited＂), (SMTP_SERVER);｝@Converter公共静态类转换器｛@Converter公共静态问题questionFromStruct (结构体结构体){（4）返回新问题(struct.getInt64 (＂id＂), struct.getString (＂文本＂), struct.getString (＂电子邮件＂));｝@Converter公共静态回答answerFromStruct (结构体结构体){（4）返回新答案(struct.getInt64 (＂id＂), struct.getString (＂文本＂), struct.getString (＂电子邮件＂), struct.getInt64 (＂question_id＂));}}}

$ MVN清洁安装

$ env TWITTER_CONSUMER_KEY=<…> TWITTER_CONSUMER_SECRET = <…> TWITTER_ACCESS_TOKEN = <…> TWITTER_ACCESS_TOKEN_SECRET = <…docker-compose up

$ curl -v -X POST -H 'Content-Type: application/json' http://0.0.0.0:8080/question/ -d @src/test/resources/messages/create-question。json$ curl -v -X POST -H 'Content-Type: application/json' http://0.0.0.0:8080/question/1/answer -d @src/test/resources/messages/create-answer1.json $ curl -v -X POST -H 'Content-Type: application/json' http://0.0.0.0:8080/question/1/answer -d @src/test/resources/messages/create-answer2.json $ curl -v -X POST -H 'Content-Type: application/json' http://0.0.0.0:8080/question/1/answer -d @src/test/resources/messages/create-answer3.json