artin/OBP-API
1
0
Fork 0
mirror of https://github.com/OpenBankProject/OBP-API.git synced 2026-02-06 17:37:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor/removed KafkaMappedConnector_vMay2019

Browse Source
This commit is contained in:
Hongwei 2025-03-06 13:18:38 +01:00
parent e4892be206
commit 166e4f2a45
5 changed files with 1 additions and 7046 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
README.kafka.md
View File

@ -1,26 +0,0 @@
## Kafka Quickstart
Note that obp with kafka connector will also need a bank backend connected to the kafka that implements the following: https://apiexplorersandbox.openbankproject.com/glossary#Adapter.Kafka.Intro
Otherwise obp will display anything but adapter errors.
#####Configuration
* Edit the OBP-API/obp-api/src/main/resources/props/default.props so that it contains the following lines:
connector=kafka_vMay2019
# kafka server location, plaintext for quickstart
kafka.host=localhost:9092
# next 2 lines for legacy resons
kafka.request_topic=Request
kafka.response_topic=Response
# number of partitions available on kafka. Must match the kafka configuration!!!!!!.
kafka.partitions=1
# no ssl for quickstart
kafka.use.ssl=false
# start with 1 for the first instance, set to 2 for the second instance etc
api_instance_id=1

2
obp-api/src/main/scala/code/bankconnectors/Connector.scala
View File

@ -12,7 +12,6 @@ import code.bankconnectors.akka.AkkaConnector_vDec2018
import code.bankconnectors.rabbitmq.RabbitMQConnector_vOct2024
import code.bankconnectors.rest.RestConnector_vMar2019
import code.bankconnectors.storedprocedure.StoredProcedureConnector_vDec2019
import code.bankconnectors.vMay2019.KafkaMappedConnector_vMay2019
import code.bankconnectors.vSept2018.KafkaMappedConnector_vSept2018
import com.openbankproject.commons.model.CounterpartyLimitTrait
import com.openbankproject.commons.model.CustomerAccountLinkTrait
@ -65,7 +64,6 @@ object Connector extends SimpleInjector {
"mapped" -> LocalMappedConnector,
"akka_vDec2018" -> AkkaConnector_vDec2018,
"kafka_vSept2018" -> KafkaMappedConnector_vSept2018,
"kafka_vMay2019" -> KafkaMappedConnector_vMay2019,
"rest_vMar2019" -> RestConnector_vMar2019,
"stored_procedure_vDec2019" -> StoredProcedureConnector_vDec2019,
"rabbitmq_vOct2024" -> RabbitMQConnector_vOct2024,

31
obp-api/src/main/scala/code/bankconnectors/vMay2019/KafkaConnectorBuilder.scala
View File

@ -1,31 +0,0 @@
package code.bankconnectors.vMay2019
import code.bankconnectors.generator.ConnectorBuilderUtil._
import scala.collection.immutable.List
import scala.language.postfixOps
object KafkaConnectorBuilder extends App {
val genMethodNames = List(
"getAdapterInfo",
"getBank",
"getBanks",
"getBankAccountsBalances",
"getBranch",
"getBranches",
"getAtm",
"getAtms",
"getCustomersByUserId",
"getCustomerByCustomerId",
"getCustomerByCustomerNumber"
)
generateMethods(commonMethodNames,
"src/main/scala/code/bankconnectors/vMay2019/KafkaMappedConnector_vMay2019.scala",
"processRequest[InBound](req)", true)
}

6980
obp-api/src/main/scala/code/bankconnectors/vMay2019/KafkaMappedConnector_vMay2019.scala
View File

File diff suppressed because it is too large Load Diff

8
obp-api/src/test/scala/code/api/v2_2_0/API2_2_0Test.scala
View File

@ -429,13 +429,7 @@ class API2_2_0Test extends V220ServerSetup with DefaultUsers {
val response: APIResponse = makeGetRequest(request)
response.code should be (200)
}
scenario("Get Message Docs - kafka_vMay2019") {
val request = (v2_2Request / "message-docs" / "kafka_vMay2019" )
val response: APIResponse = makeGetRequest(request)
response.code should be (200)
}
}
scenario("Get Message Docs - rest_vMar2019") {
val request = (v2_2Request / "message-docs" / "rest_vMar2019" )
val response: APIResponse = makeGetRequest(request)