watch

func DecodeTxnOpaques(ctx context.Context, txn *rkcypb.ApecsTxn, concernHandlers rkcy.ConcernHandlers, pjOpts *protojson.MarshalOptions) ([]byte, error)

func Start(
	ctx context.Context,
	wg *sync.WaitGroup,
	strmprov rkcy.StreamProvider,
	platform string,
	environment string,
	adminBrokers string,
	cncHdlrs rkcy.ConcernHandlers,
	watchDecode bool,
)

func WatchResultTopics(
	ctx context.Context,
	wg *sync.WaitGroup,
	strmprov rkcy.StreamProvider,
	platform string,
	environment string,
	adminBrokers string,
	cncHdlrs rkcy.ConcernHandlers,
	watchDecode bool,
)