Acceptance Criteria

• Port the OfferingSyncController and all the dependencies from the monolith to swatch-contracts
• Including the Kafka configuration and tests
• Test using /internal/rpc/offerings/sync which calls syncAllOfferings()
• This will trigger syncing via the tasks messages at 
  org.candlepin.subscriptions.product.OfferingWorker#receive(org.candlepin.subscriptions.product.OfferingSyncTask)
• Add an Unleash feature flag that controls whether message processing is handled in swatch-contracts or in swatch-subscription-sync

For SubscriptionSyncController

• Including all the classes under the package “org.candlepin.subscriptions.subscription”
• Including the Kafka configuration and tests
• Test using /internal/subscriptions/sync/org/{org_id}:
  • org.candlepin.subscriptions.subscription.SubscriptionSyncController#forceSyncSubscriptionsForOrgAsync
  • And also kafka via org.candlepin.subscriptions.subscription.SubscriptionWorker#receive(org.candlepin.subscriptions.subscription.SyncSubscriptionsTask, org.springframework.kafka.support.Acknowledgment)
• The rest endpoint in swatch-contracts should be /internal/rpc/subscriptions/sync/org/{org_id} to match the general structure of other swatch-contracts internal API endpoints. 
• Update the methods that were left empty in SWATCH-2276 to use the correct ones
• Port SubscriptionWorker.receive (JmsListener) to SubscriptionCanonicalMessageConsumer.receive in swatch-contracts
• Port SubscriptionWorker.receive (KafkaListener) to swatch-contracts

For all:

• Create the “subscription-sync” and “offering-sync” cronjobs to the swatch-contracts deployment